如何使用python多线程并返回值？

舞夢輝影

发布： 2025-12-02 21:15:06

原创

391人浏览过

Python中推荐使用concurrent.futures.ThreadPoolExecutor获取多线程返回值：通过submit()返回Future对象并调用result()获取结果，或用as_completed()按完成顺序处理，或用map()按输入顺序批量执行。

如何使用python多线程并返回值？

Python中使用多线程并获取返回值，可以通过多种方式实现。最常用的是结合concurrent.futures.ThreadPoolExecutor和submit()方法，这种方式简洁且支持返回值的获取。

ThreadPoolExecutor 是 concurrent.futures 模块中的高级接口，能方便地管理线程池，并通过 Future 对象获取执行结果。

from concurrent.futures import ThreadPoolExecutor import time

def task(n): time.sleep(1) return n * n

创建线程池，提交多个任务

with ThreadPoolExecutor(max_workers=3) as executor: futures = [executor.submit(task, i) for i in range(5)]

# 获取返回值
for future in futures:
    print(future.result())  # 会阻塞直到结果可用

登录后复制

说明：

如果你希望哪个线程先执行完就先处理其结果，可以用 as_completed()：

话袋AI笔记

话袋AI笔记, 像聊天一样随时随地记录每一个想法，打造属于你的个人知识库，成为你的外挂大脑

195

from concurrent.futures import ThreadPoolExecutor, as_completed

def task(n): import time time.sleep(n) return f"task {n} done"

with ThreadPoolExecutor(max_workers=3) as executor: tasks = [executor.submit(task, i) for i in [2, 1, 3]]

for future in as_completed(tasks):
    print(future.result())

登录后复制

输出顺序将按执行完成时间排列，而不是提交顺序。

如果任务是同一种函数处理不同参数，executor.map() 更简洁：

with ThreadPoolExecutor(max_workers=3) as executor: results = executor.map(task, [1, 2, 3, 4]) for result in results: print(result)

map 返回迭代器，按输入顺序返回结果，适合不需要并发等待控制的场景。

基本上就这些。用 ThreadPoolExecutor 是目前最推荐的方式，既能并发执行，又能安全获取返回值，无需手动管理线程和共享变量。

以上就是如何使用python多线程并返回值？的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

使用 ib_insync 从交易对象中获取合约ID (conID) MySQL查询在Flask应用中无结果：版本兼容性是关键 python3 hex函数是什么？怎么用？如何掌握Python3中PyMongo的用法？ python shape函数如何使用？