为什么 pool(进程池)返回的对象赋值给类属性就无法调用子进程

Question

为什么 pool返回的对象赋值给类属性就无法调用子进程

from multiprocessing import Pool

class t(object):

    def __init__(self):
        self.p = Pool(4)

    def _proc(self, name):
        print('run {}'.format(name))

    def run(self):
        for i in [1,2]:
            #无效
            self.p.apply_async(self._proc, (i,))


if __name__ == '__main__':
    foo = t()
    foo.run()
    print('end')

如果不能，怎么解决?

Answer 1

因为主进程结束了，子进程来不及执行

def run(self):
        for i in [1,2]:
            #无效
            self.p.apply_async(self._proc, (i,))
        self.p.close()
        self.p.join()

Answer 2

那怎么用pool 来运行类方法呢??