import multiprocessing |
def worker(num): |
"""进程执行的任务""" |
print (f 'Worker {num} 开始执行' ) |
# 执行一些任务... |
print (f 'Worker {num} 完成执行' ) |
if __name__ = = '__main__' : |
# 创建进程池,最大进程数为4 |
pool = multiprocessing.Pool(processes = 4 ) |
# 启动10个进程,每个进程执行worker函数 |
for i in range ( 10 ): |
pool.apply_async(worker, args = (i,)) |
# 关闭进程池,阻止新的进程加入 |
pool.close() |
# 等待所有进程执行完毕 |
pool.join() |
print ( '所有进程执行完毕' ) |