python ThreadPoolExecutor demo
时间: 2023-10-17 22:01:55 浏览: 105
当然,我可以为您展示一个 Python 中使用 ThreadPoolExecutor 的简单示例。
首先,我们需要导入 `concurrent.futures` 模块中的 `ThreadPoolExecutor` 类。然后,我们可以创建一个线程池对象,并指定要使用的线程数量。
接下来,我们可以定义一个函数作为要执行的任务。在本示例中,我们将创建一个简单的函数来模拟任务,并让每个任务休眠一段时间以模拟耗时操作。
最后,我们使用线程池对象的 `submit` 方法将任务提交给线程池进行处理,并使用 `result` 方法获取任务的返回结果。
下面是一个简单的示例代码:
```python
import time
from concurrent.futures import ThreadPoolExecutor
def task(n):
print(f"Executing task {n}")
time.sleep(1)
return f"Task {n} completed"
# 创建线程池,并指定使用2个线程
with ThreadPoolExecutor(max_workers=2) as executor:
# 提交任务给线程池进行处理
futures = [executor.submit(task, i) for i in range(5)]
# 获取任务的返回结果
for future in futures:
print(future.result())
```
上述示例中,我们创建了一个线程池,其中包含2个线程。然后,我们将5个任务提交给线程池进行处理。每个任务都会休眠1秒钟,然后返回一个完成消息。
最后,我们迭代所有任务的返回结果,并将其打印出来。
希望这个示例对您有所帮助!如有任何疑问,请随时提出。
阅读全文