以下是一个使用并行的Multiprocessing.Process
的代码示例:
import multiprocessing
def worker(num):
"""子进程的任务"""
print(f'Worker {num} 开始')
return
if __name__ == '__main__':
processes = []
num_processes = 4
for i in range(num_processes):
# 创建并启动子进程
p = multiprocessing.Process(target=worker, args=(i,))
p.start()
processes.append(p)
for p in processes:
# 等待所有子进程完成
p.join()
解释:
worker
函数是子进程要执行的任务。这里只是简单地打印出一个消息。processes
列表来保存所有子进程的引用。worker
函数,并传递一个唯一的标识符(i
)作为参数。join
方法来实现。这将阻塞主进程,直到子进程完成为止。运行这段代码将创建并行的子进程,每个子进程都会执行worker
函数。你可以根据需要更改num_processes
变量来控制并行子进程的数量。
上一篇:并行的流水线构建导致了git冲突
下一篇:并行的PHP进程