
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('所有进程执行完毕')


