登录
首页 >  文章 >  python教程

Python多线程获取结果的几种方法

时间:2025-12-18 15:40:54 206浏览 收藏

推广推荐
免费电影APP ➜
支持 PC / 移动端,安全直达

今天golang学习网给大家带来了《Python多线程获取返回值方法详解》,其中涉及到的知识点包括等等,无论你是小白还是老手,都适合看一看哦~有好的建议也欢迎大家在评论留言,若是看完有所收获,也希望大家能多多点赞支持呀!一起加油学习~

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

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

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

使用 ThreadPoolExecutor 获取线程返回值

ThreadPoolExecutorconcurrent.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())  # 会阻塞直到结果可用

说明:

  • executor.submit() 提交函数并返回一个 Future 对象
  • future.result() 用于获取执行结果,若任务未完成则阻塞等待
  • 可以按顺序或使用 as_completed() 获取最先完成的任务结果

使用 as_completed 提前获取已完成任务的结果

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

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())

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

使用 map 简化批量任务

如果任务是同一种函数处理不同参数,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多线程获取结果的几种方法》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多文章知识!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>