阅读量:4
在Python中,可以使用concurrent.futures
模块来实现多线程并获取返回值。具体步骤如下:
- 导入
concurrent.futures
模块:
import concurrent.futures
- 定义一个函数来执行多线程任务,该函数返回需要获取的值:
def task(): # 执行任务 return result
- 创建一个线程池对象:
executor = concurrent.futures.ThreadPoolExecutor()
- 提交任务到线程池,并获取Future对象:
future = executor.submit(task)
- 调用Future对象的
result()
方法获取返回值:
result = future.result()
完整示例代码如下:
import concurrent.futures def task(): # 执行任务 return result executor = concurrent.futures.ThreadPoolExecutor() future = executor.submit(task) result = future.result() print(result)
注意:future.result()
方法是一个阻塞方法,会等待任务执行完毕并返回结果。如果任务没有执行完毕,调用该方法会阻塞当前线程。如果需要并发执行多个任务并获取所有结果,可以使用as_completed()
方法和executor.map()
方法。