使用 ThreadPoolExecutor 创建多线程
时间: 2023-08-19 12:15:14 浏览: 113
要使用ThreadPoolExecutor创建多线程,首先需要导入`concurrent.futures`模块。然后,可以使用ThreadPoolExecutor类来创建线程池,并指定线程池的大小。下面是一个示例代码:
```python
import concurrent.futures
# 创建线程池,指定线程池大小为5
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
# 提交任务给线程池
future1 = executor.submit(func1, arg1, arg2)
future2 = executor.submit(func2, arg3, arg4)
future3 = executor.submit(func3, arg5, arg6)
# 获取任务的结果
result1 = future1.result()
result2 = future2.result()
result3 = future3.result()
```
在上面的代码中,我们创建了一个大小为5的线程池。然后,使用`executor.submit()`方法提交任务给线程池,每个任务都会返回一个`Future`对象。可以使用`future.result()`方法来获取任务的结果。
请注意,`func1`、`func2`和`func3`是需要执行的函数,`arg1`、`arg2`、`arg3`等是函数的参数。你可以根据自己的需求来定义和调用这些函数。
这样,就可以使用ThreadPoolExecutor创建多线程并执行任务了。
阅读全文