callable ThreadPoolExecutor的使用
时间: 2024-04-30 21:16:23 浏览: 74
callable ThreadPoolExecutor是Python中的一个线程池执行器,它可以用于并发执行可调用对象(callable)。可调用对象可以是函数、方法或者类的实例方法。下面是callable ThreadPoolExecutor的使用方式:
1. 导入ThreadPoolExecutor模块:
```python
from concurrent.futures import ThreadPoolExecutor
```
2. 创建ThreadPoolExecutor对象:
```python
executor = ThreadPoolExecutor(max_workers=5)
```
这里的max_workers参数指定了线程池中最大的线程数量。
3. 提交任务给线程池执行:
```python
future = executor.submit(callable_object, *args, **kwargs)
```
这里的callable_object是一个可调用对象,*args和**kwargs是传递给可调用对象的参数。submit()方法会返回一个Future对象,可以通过该对象获取任务的执行结果。
4. 获取任务的执行结果:
```python
result = future.result()
```
result变量将保存任务的执行结果。如果任务还没有完成,result()方法会阻塞直到任务完成并返回结果。
5. 关闭线程池:
```python
executor.shutdown()
```
调用shutdown()方法会等待所有任务执行完毕后关闭线程池。
阅读全文