主页 > TokenPocket下载 > 「TokenPocket官方网址」详解Python获取线程返回值的三种方式

「TokenPocket官方网址」详解Python获取线程返回值的三种方式

admin TokenPocket下载 2022年07月08日

helloworld!8
helloworld!1
helloworld!2
方法一

使用全局变量的列表,来保存返回值

helloworld!3

默认的 thread.join() 方法只是等待线程函数结束,没有返回值,我们可以在此处返回函数的运行结果,代码如下:

from threading import Thread def foo(arg):     return arg class ThreadWithReturnValue(Thread):     def run(self):         if self._target is not None:             self._return = self._target(*self._args, **self._kwargs)     def join(self):         super().join()         return self._return twrv = ThreadWithReturnValue(target=foo, args=("hello world",)) twrv.start() print(twrv.join()) # 此处会打印 hello world。

这样当我们调用 thread.join() 等待线程结束的时候,也就得到了线程的返回值。

helloworld!0

我觉得前两种方式实在太低级了,Python 的标准库 concurrent.futures 提供更高级的线程操作,可以直接获取线程的返回值,相当优雅,代码如下:

关于详解Python获取线程返回值的三种方式的文章就介绍至此,更多相关Python获取线程返回值内容请搜索编程宝库以前的文章,希望以后支持编程宝库!

helloworld!6

最后的话

本文分享了获取线程返回值的 3 种方法,推荐使用第三种

方法三

使用标准库 concurrent.futures

helloworld!9

项目背景作为数据分析师,我们需要经常制作统计分析图表。但是报表太多的时候往往需要花费我们大部分时间去制作报表。这耽误了我们利用大量的时间去进行数据分析。但是作为数据分析师我们应该尽可能 ...

下一节:基于Python实现报表自动化并发送到邮箱Python编程技术

import concurrent.futures def foo(bar):     return bar with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:     to_do = []     for i in range(10):  # 模拟多个任务         future = executor.submit(foo, f"hello world! {i}")         to_do.append(future)     for future in concurrent.futures.as_completed(to_do):  # 并发执行         print(future.result())

某次运行的结果如下:

helloworld!5

如果事先知道有多少个线程,可以定义一个固定长度的列表,然后根据索引来存放返回值,比如:

ret_values = [] def thread_func(*args):     ...     value = ...     ret_values.append(value)

选择列表的一个原因是:列表的 append() 方法是线程安全的,CPython 中,GIL 防止对它们的并发访问。如果你使用自定义的数据结构,在并发修改数据的地方需要加线程锁。

详解Python获取线程返回值的三种方式

提到线程,你的大脑应该有这样的印象:我们可以控制它何时开始,却无法控制它何时结束,那么如何获取线程的返回值呢?今天就分享一下自己的一些做法。

helloworld!4
helloworld!7
from threading import Thread threads = [None] * 10 results = [None] * 10 def foo(bar, result, index):     result[index] = f"foo-{index}" for i in range(len(threads)):     threads[i] = Thread(target=foo, args=('world!', results, i))     threads[i].start() for i in range(len(threads)):     threads[i].join() print (" ".join(results)) 方法二

重写 Thread 的 join 方法,返回线程函数的返回值

广告位
标签: Python线程返   Python