python之线程池map()方法传递多参数list

线程池是Python中处理函数并发执行的方案之一，其中map()方法可以并行地迭代处理一组参数列表中的多个函数。以下是使用线程池ThreadPoolExecutor及其map()方法进行并发处理的完整攻略。

1. 导入必要的模块

在使用线程池之前，需要导入concurrent.futures模块中的ThreadPoolExecutor类。同时，为了实现多参数列表的传递，我们还需要导入itertools模块。

from concurrent.futures import ThreadPoolExecutor
import itertools

2. 准备函数和参数列表

为了方便演示，我们假设有一个名为power的计算平方数的函数，并准备以下参数列表：

args_list = [(2,), (4,), (6,), (8,), (10,)]

这个参数列表包含了5个元素，每个元素都是一个只含一个整型值的元组，用于计算其平方。

3. 使用ThreadPoolExecutor创建线程池

接下来，我们使用ThreadPoolExecutor类创建线程池，并将其赋值给一个变量executor。

with ThreadPoolExecutor(max_workers=5) as executor:

注意这里的max_workers参数表示线程池中最多可同时执行的线程数。

4. 使用map()方法执行函数

最后，我们使用map()方法在线程池中并行执行power函数，并传入我们准备好的参数列表。

    results = executor.map(power, *args_list)

由于map()方法期待传入的参数是多个参数列表而非一个参数列表中包含多个元素，因此我们使用了*运算符将args_list列表中的每个元素解包成单独的参数。

5. 输出结果

为了获取函数返回的结果，我们可以使用list()函数将results对象转换成列表，并用for循环遍历输出每个计算结果。

    results_list = list(results)
    for result in results_list:
        print(result)

完整代码：

from concurrent.futures import ThreadPoolExecutor
import itertools

def power(n):
    return n ** 2

args_list = [(2,), (4,), (6,), (8,), (10,)]

with ThreadPoolExecutor(max_workers=5) as executor:
    results = executor.map(power, *args_list)
    results_list = list(results)
    for result in results_list:
        print(result)

示例输出：

示例2：使用多个参数列表并行执行函数

以一个计算两个数之和的函数为例，假设我们有两个参数列表，一个列表中的元素表示所有的a值，另一个列表中的元素表示所有的b值，我们可以将两个参数列表分别解包后传递给map函数进行并行执行。

from concurrent.futures import ThreadPoolExecutor
import itertools

def add(a, b):
    return a + b

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

with ThreadPoolExecutor(max_workers=5) as executor:
    results = executor.map(add, a_list, b_list)
    results_list = list(results)
    for result in results_list:
        print(result)