python pool.map 多线程 多参数
pool.map默认只能传入一个参数，包上一个lambda分发参数，即可解决多参数传入问题
from multiprocessing import Pool
from multiprocessing.dummy import Pool as ThreadPool
def execThread(func, args, pool_size=12):
pool = ThreadPool(pool_size)
if len(args) == 1 or len(args[0]) == 1:
res = pool.map(func, args)
else:
fun = lambda x: func(*x)
res = pool.map(fun, args)
pool.close()
pool.join()
return res
def __pool_test(a, b):
import time
time.sleep(a)
print(a)
return a + b
if __name__ == '__main__':
data = [
(1, 2),
(2, 2),
(3, 2),
(4, 2),
]
res = execThread(__pool_test, data)
print(res)