如何创建 ThreadPoolExecutor 对象?
浏览量:128
点赞量:0
要创建ThreadPoolExecutor对象,您需要从concurrent.futures模块导入ThreadPoolExecutor类,并使用构造函数创建一个新的ThreadPoolExecutor对象。构造函数需要一个整数参数,表示线程池的大小。例如,以下代码创建一个大小为10的线程池:
```python
from concurrent.futures import ThreadPoolExecutor
executor = ThreadPoolExecutor(10)
```
在这个例子中,executor是一个新的ThreadPoolExecutor对象,它具有10个线程。现在,您可以将任务提交到线程池中,并等待它们完成。例如,以下代码提交了一个简单的任务,并等待它完成:
```python
def my_task():
print('Hello, world!')
future = executor.submit(my_task)
result = future.result()
```
在这个例子中,我们定义了一个简单的函数my_task(),它打印一条消息。然后,我们使用executor.submit()方法将这个任务提交到线程池中,并返回一个future对象。最后,我们使用future.result()方法等待任务完成,并获取任务的结果。在这个例子中,任务只是打印了一条消息,因此结果是None。
说明:本站所有资源仅供学习与参考,如有侵犯您的版权,请及时联系liuqiang@zjkytwl.com,我们将尽快处理。
贡献者:
薄露如霜
邮箱:
捐赠: