我可以为您提供一个多进程执行的示例代码,您可以根据自己的需求进行修改和适应。
```import multiprocessing
def worker(task):
# 在这里执行具体的任务
print(f"Processing task: {task}")
if name == 'main':
tasks = [1, 2, 3, 4, 5] # 假设这是待处理的任务列表
# 创建进程池,根据需求设置进程数
pool = multiprocessing.Pool(processes=4)
# 使用进程池中的进程执行任务
pool.map(worker, tasks)
# 关闭进程池
pool.close()
pool.join()
```
在上面的示例中,我们首先定义一个 worker 函数,它表示具体的任务执行逻辑。然后,在 if name == 'main': 的条件语句中,创建了一个进程池 pool,并设置了要使用的进程数。接下来,使用 pool.map() 函数将任务列表 tasks 分发给进程池中的进程进行处理。最后,关闭进程池并等待所有进程执行完毕。
请注意,这只是一个简单的示例代码,您可以根据需要进行更复杂的任务处理,并根据实际情况调整进程池的大小和任务列表。
希望以上信息对您有所帮助!如有任何进一步的问题,请随时提问。