Python3 multiprocessing — 像管理线程一样管理进程
import multiprocessing
def worker(num):
"""
一个简单的工作函数，接受一个数字并打印出相应的信息。
"""
print(f"Worker {num} is running...")
if __name__ == "__main__":
# 创建一个进程池，进程池的大小为4
with multiprocessing.Pool(processes=4) as pool:
# 向进程池提交工作任务，会自动创建并管理进程
for i in range(4):
pool.apply_async(worker, (i,))
# 主进程继续执行其他任务或者等待所有子进程完成
print("Main process doing other work...")这段代码演示了如何使用Python的multiprocessing库创建一个进程池，并向其中提交工作任务。通过apply_async方法，我们可以向进程池提交函数worker的多个实例执行。这样可以有效地利用多核处理器，并管理进程的创建和销毁。
评论已关闭