concurrent.futures.ProcessPoolExecutor()语法

Concurrent.futures.ProcessPoolExecutor()是一个使用进程池作为并行执行工具的高级并发包。它提供了一种简单的方式来并发执行CPU密集型函数和外部命令。下面是一个使用ProcessPoolExecutor()的简单示例:

import concurrent.futures

# 以下是要并行执行的函数
def my_function(x):
    return x**2

a_list = [1,2,3,4,5]

# 用进程池自动分配任务
with concurrent.futures.ProcessPoolExecutor() as executor:
    results = executor.map(my_function, a_list)

# 打印结果
for result in results:
    print(result)

在这里，my_function()函数将并行执行，并且将a_list中的每个元素作为输入。ProcessPoolExecutor()将根据CPU核心数量自动分配进程来执行每个任务，并且根据任务完成顺序产生结果。