Python创建进程池完成任务
时间: 2024-02-02 22:44:17 浏览: 66
Python的multiprocessing模块提供了创建进程池的功能,可以方便地完成多个任务的并发执行。下面是一个简单的示例,展示了如何使用进程池完成任务:
```python
import multiprocessing
def task(num):
print("Processing task {}".format(num))
if __name__ == '__main__':
# 创建进程池
pool = multiprocessing.Pool(processes=4)
# 提交任务
for i in range(10):
pool.apply_async(task, args=(i,))
# 关闭进程池,等待任务完成
pool.close()
pool.join()
```
在上面的示例中,我们首先创建了一个包含4个进程的进程池。然后,我们使用`apply_async()`方法向进程池中提交了10个任务。这些任务将被异步地分配给进程池中的进程进行执行。
最后,我们关闭了进程池,并使用`join()`方法等待所有任务完成。在任务执行期间,我们可以看到输出结果类似于:
```
Processing task 0
Processing task 1
Processing task 2
Processing task 3
Processing task 4
Processing task 5
Processing task 6
Processing task 7
Processing task 8
Processing task 9
```
这表明进程池中的进程已经完成了所有任务的并发执行。
阅读全文