在新的shell中启动multiprocessing.Pool中的每个worker可以通过以下步骤实现:
import multiprocessing
def worker_task():
# 在这里编写每个worker的任务代码
pass
pool = multiprocessing.Pool(processes=4) # 这里指定启动4个worker
pool.map(worker_task, range(4)) # 这里假设有4个任务需要执行
在上述代码中,我们使用了range(4)来表示有4个任务需要执行。你可以根据实际情况修改这个范围。
这样,每个worker将在新的shell中启动,并执行worker_task函数中定义的任务。
关于multiprocessing.Pool的更多信息和用法,你可以参考腾讯云的产品介绍链接:multiprocessing.Pool产品介绍
领取专属 10元无门槛券
手把手带您无忧上云