Python进程池multiprocessing.Pool
Python的multiprocessing
模块提供了进程池的功能,可以方便地创建多个进程并发执行任务。以下是一个使用multiprocessing.Pool
的例子:
from multiprocessing import Pool
def f(x):
return x * x
if __name__ == '__main__':
with Pool(processes=4) as pool: # 创建容量为4的进程池
result = pool.map(f, range(10)) # 并发执行f(0), f(1), ..., f(9)
print(result) # 输出: [0, 1, 4, 9, 16, 25, 36, 49, 64, 81]
在这个例子中,我们定义了一个函数f
,它接受一个数字并计算其平方。然后我们创建了一个容量为4的进程池,并使用pool.map
函数来并发地对range(10)
中的每个数字应用f
函数。最后,我们打印出结果列表,显示了所有任务并发执行的效果。
评论已关闭