想通过使用multiprocessing.pool.apply_async多进程实现一个小功能,在
a[]后不断增加func()的返回值。但是在使用apply_async().get()函数后,子进行并未执行,程序仍然按照顺序执行,运行时间也未减少,约4秒,但是在仅运行apply_async()打印时,程序运行时间几乎是按进程数减少的,约2秒。
如何才能实现多进程获取返回值?
求教各位大神!
import time
start = time.time()
def func(args1):
time.sleep(1)
print(args1)
return (args1 ** 2)
from multiprocessing import Pool
if __name__ == "__main__":
pool = Pool(2)
a = []
for i in range(4):
a.append(pool.apply_async(func, (i,)).get())
pool.close()
pool.join()
print(a)
end = time.time()
print('Running time: %.2f Seconds' % (end - start))