1

我已经并行化了一些代码,但需要保留订单作业与收到的订单一起提交

一段时间以来,我一直在为此努力,但一无所获

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))

这样它就会执行计数器时间

4

0 回答 0