为什么map_async()不需要pool.close()和pool.join()？

Question

我写了以下代码

import multiprocessing as mp
import time


#
def f(x) :
    time.sleep(0.1)
    return pow( x, 2 )

#
my_chunksize = 10

#
if __name__ == '__main__':

    #
    po = mp.Pool( processes=2 )
    po_res = po.map_async( f, range(100), my_chunksize )

    #po.close()
    #po.join()

    #
    print po_res.get()

这很好用。为什么不需要po.close()和po.join()？为什么主进程不死在子进程之前？

Answer 1

你的期末考试：

print po_res.get()

语句阻塞主程序，直到map_async()完全完成为止。阻塞的是.get()，等待整个结果列表可用。在传递给map_async()的所有工作完成并将所有结果返回到主程序之前，这是不可能的。

将该声明注释掉，您将看到您的程序很快退出。

尽管如此，不管如何使用.close()和.join()都是最佳实践。