如何从 Python 中的线程获取返回值？

Question

下面的函数 foo 返回一个字符串 'foo' 。如何获取从线程目标返回的值 'foo' ？

 from threading import Thread

def foo(bar):
    print('hello {}'.format(bar))
    return 'foo'

thread = Thread(target=foo, args=('world!',))
thread.start()
return_value = thread.join()

上面显示的“一种明显的方法”不起作用： thread.join() 返回 None 。

原文由 wim 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

在 Python 3.2+ 中，stdlib concurrent.futures 模块为 threading 提供了更高级别的 API，包括将工作线程的返回值或异常传递回主线程：

 import concurrent.futures

def foo(bar):
    print('hello {}'.format(bar))
    return 'foo'

with concurrent.futures.ThreadPoolExecutor() as executor:
    future = executor.submit(foo, 'world!')
    return_value = future.result()
    print(return_value)

原文由 Ramarao Amara 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

我见过的一种方法是将可变对象（例如列表或字典）连同索引或其他某种标识符一起传递给线程的构造函数。然后线程可以将其结果存储在该对象的专用槽中。例如：

 def foo(bar, result, index):
    print 'hello {0}'.format(bar)
    result[index] = "foo"

from threading import Thread

threads = [None] * 10
results = [None] * 10

for i in range(len(threads)):
    threads[i] = Thread(target=foo, args=('world!', results, i))
    threads[i].start()

# do some other stuff

for i in range(len(threads)):
    threads[i].join()

print " ".join(results)  # what sound does a metasyntactic locomotive make?

如果你真的想要 join() 返回被调用函数的返回值，你可以使用 Thread 子类来实现，如下所示：

 from threading import Thread

def foo(bar):
    print 'hello {0}'.format(bar)
    return "foo"

class ThreadWithReturnValue(Thread):
    def __init__(self, group=None, target=None, name=None,
                 args=(), kwargs={}, Verbose=None):
        Thread.__init__(self, group, target, name, args, kwargs, Verbose)
        self._return = None
    def run(self):
        if self._Thread__target is not None:
            self._return = self._Thread__target(*self._Thread__args,
                                                **self._Thread__kwargs)
    def join(self):
        Thread.join(self)
        return self._return

twrv = ThreadWithReturnValue(target=foo, args=('world!',))

twrv.start()
print twrv.join()   # prints foo

由于一些名称修改，这变得有点毛茸茸，它访问特定于 Thread 实现的“私有”数据结构……但它有效。

对于 Python 3：

 class ThreadWithReturnValue(Thread):

    def __init__(self, group=None, target=None, name=None,
                 args=(), kwargs={}, Verbose=None):
        Thread.__init__(self, group, target, name, args, kwargs)
        self._return = None

    def run(self):
        if self._target is not None:
            self._return = self._target(*self._args,
                                                **self._kwargs)
    def join(self, *args):
        Thread.join(self, *args)
        return self._return

原文由 kindall 发布，翻译遵循 CC BY-SA 4.0 许可协议