4. ThreadPoolExecutor
时间: 2024-04-19 14:22:48 浏览: 69
Java进阶之ThreadPoolExecutor
ThreadPoolExecutor是Python标准库concurrent.futures模块中的一个类,用于创建一个线程池来执行并发任务。它提供了一种简单的方式来管理和调度多个线程,并且可以方便地处理并发任务的结果。
下面是一个使用ThreadPoolExecutor的例子[^1]:
```python
from concurrent.futures import ThreadPoolExecutor
# 定义一个任务函数
def task(n):
return n * n
# 创建一个线程池
with ThreadPoolExecutor() as executor:
# 提交任务到线程池
future = executor.submit(task, 5)
# 获取任务的结果
result = future.result()
print(result) # 输出:25
```
在这个例子中,我们首先定义了一个任务函数task,它接受一个参数n,并返回n的平方。然后,我们使用ThreadPoolExecutor创建了一个线程池executor。接下来,我们使用executor.submit方法提交了一个任务到线程池,并传入参数5。submit方法返回一个Future对象,代表了任务的未来结果。我们可以使用Future对象的result方法来获取任务的结果。
需要注意的是,ThreadPoolExecutor会自动管理线程的创建和销毁,我们只需要关注任务的提交和结果的获取即可。
阅读全文