Python进程池代码
时间: 2024-04-16 15:22:53 浏览: 105
Python进程池是一种并发编程的技术,它可以用于管理和调度多个子进程,提高程序的执行效率。下面是一个简单的Python进程池代码示例:
```python
import multiprocessing
def worker(num):
"""子进程的工作函数"""
print(f"Worker {num} is executing")
if __name__ == "__main__":
# 创建进程池,设置最大进程数为3
pool = multiprocessing.Pool(processes=3)
# 启动子进程,每个子进程执行worker函数,并传入不同的参数
for i in range(5):
pool.apply_async(worker, args=(i,))
# 关闭进程池,不再接受新的任务
pool.close()
# 等待所有子进程执行完毕
pool.join()
print("All workers have finished")
```
上述代码中,首先导入了`multiprocessing`模块,然后定义了一个`worker`函数作为子进程的工作函数。在主程序中,通过`multiprocessing.Pool`创建了一个进程池,并设置最大进程数为3。然后使用`pool.apply_async`方法启动子进程,每个子进程执行`worker`函数,并传入不同的参数。最后,调用`pool.close()`关闭进程池,并使用`pool.join()`等待所有子进程执行完毕。
阅读全文