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