我已经并行化了一些代码,但需要保留订单作业与收到的订单一起提交
一段时间以来,我一直在为此努力,但一无所获
import concurrent.futures
par_result = []
with concurrent.futures.ProcessPoolExecutor(big_number) as executor:
future_thing = [executor.submit(fnc, param1, param2,\
counter) for counter in range(another_number)]
for future in concurrent.futures.as_completed(future_thing):
par_result.append(future.result())
如何将其重写为类似的格式
with concurrent.futures.ProcessPoolExecutor(big_number) as executor:
par_results = executor.map(fnc, (param1, param2, counter))
这样它就会执行计数器时间