Python实现从线程获取返回值_开发_开发者

在Python中使用多线程的HelloWorld程序

考虑以下代码：

from threading import Thread

# 一个线程的函数
def first_function():
    print('Hello World')

print("main program start")

thread_1 = Thread(target=first_function)
thread_2 = Thread(target=first_function)
thread_1.start()
thread_2.start()

print("main ends")

在上面的代码中，首先我们使用 from threading import Thread 语句导入 Thread 类以使用多线程功能。我们定义了一个名为 first_function() 的函数，用于显示 “Hejsllo World”，并使用 Thread() 类实例化了两个线程对象。

我们通过将 first_function() 作为目标函数传递给 Thread() 来创建了两个 Thread() 类的实例。target 属性指定要由 Thread() 执行的函数。

一旦创建了 Thread() 实例，我们可以使用 .start() 方法运行和执行这些线程。

在线程中传递参数给函数

考虑以下代码：

from threading import Thread

def first_function(name, id):
    print('Hello World from', name, "ID=", id)

thread_1 = Thread(target=first_function, args=("Thread 1", 1))
thread_2 = Thread(target=first_function, args=("Thread 2", 2))
thread_1.start()
thread_2.start()

在上面的代码中，我们定义了一个名为 first_function(name, id) 的函数，它接收两个参数 name 和 id。我们使用 args 在 Thread 类中将这些参数作为元组传递。

我们创建了两个 Thread 类对象，并分别将参数 args=("Thread 1", 1) 和 args=("Thread 2", 2) 传递给 thread_1 和 thread_2。然后，我们使用 thread_1.start() 和 thread_2.start() 来运行这些线程。

在Python中从运行在线程中的函数中获取返回值

有多种方法可以从在线程中运行的函数中获取返回值。

传递一个可变对象给函数

我们可以通过将一个可变对象传递给在线程中运行的函数来获取函数的返回值；函数将返回值放在该对象中。

考虑以下代码：

from threading import Thread

def first_function(first_argu, return_val):
    print(first_argu)
    return_val[0] = "Return Value from " + first_argu

return_val_from_1 = [None] * 1
return_val_from_2 = [None] * 1

thread_1 = Thread(target=first_function, args=("Thread 1", return_val_from_1))
thread_2 = Thread(target=first_function, args=("Thread 2", return_val_from_2))

thread_1.start()
thread_2.start()

thread_1.join()
thread_2.join()

print(return_val_from_1)
print(return_val_from_2)

上面的代码定义了一个名为 first_function 的函数，它接收两个参数 first_argu 和 return_val。first_function 显示 first_argu 的值，并将返回值放在 return_val 的索引 0 处。

我们使用 Thread 类创建线程，并传递两个参数，包括一个列表 args=("Thread 1", return_val_from_1) 和 args=("Thread 2", return_val_from_2) 分别给 thread_1 和 thread_2。

return_valandroid_from_1 和 return_val_from_2 用于获取函数的返回值。

thread_1.join() 和 thread_2.join() 用于等待主程序完成这两个线程。

让我们看一下上述代码片段的输出：

Python实现从线程获取返回值

使用 join 方法

join 方法是另一种从在线程中获取返回值的方法。

考虑以下代码：

from threading import Thread

def first_function(first_argu):
    print(first_argu)
    return "Return Value from " + first_argu

class NewThread(Thread):
    def __init__(self, group=None, target=None, name=http://www.devze.comNone,
                 args=(), kwargs={}):
        Thread.__init__(self, group, target, namepython, args, kwargs)
    def run(self):
        if self._target != None:
            self._return = self._target(*self._args, **self._kwargs)
    def join(self, *args):
        Thread.join(self, *args)
        return self._return

thread_1 = NewThread(target=first_function, args=("Thread 1",))
thread_2 = NewThread(target=first_function, args=("Thread 2",))

thread_1.start()
thread_2.start()

print(thread_1.join())
print(thread_2.join())

在上面的代码中，我们定义了一个名为 NewThread 的自定义类，它是 Thread 类的子类。我们重新定义了 run 和 join 方法。

一旦我们创建并启动了一个线程，join() 方法将返回从 first_function 返回的值。

以下是上述代码的输出：

Python实现从线程获取返回值