[已解决]关于进程池Pool的问题

Ootme

from multiprocessing import Pool


def worker(msg):
    print(msg)


po = Pool(3)
for i in range(0,10):
    po.apply_async(worker,(i,))


print('----start----')
po.close()
po.join()
print('----end-----')

这个代码怎么怎么运行都没有结果，不会结束啊...

最佳答案

月排行榜 / 总排行榜

tjuwlb

2020-2-29 11:15:22

原因：多进程需要在main函数中运行

解决方法：加main函数，在main中调用

from multiprocessing import Pool


def worker(msg):
    print(msg)


def main():
    po = Pool(10)
    for i in range(0, 10):
        po.apply_async(worker, (i,))
    print('----start----')
    po.close()
    po.join()
    print('----end-----')


if __name__ == "__main__":
    main()

跳转到最佳答案楼层

qiuyouzhi

这样试试：

from multiprocessing import Pool


def worker(msg):
    print(msg)


po = Pool(3)
for i in range(0,10):
    po.apply_async(worker,(i,))


print('----start----')
po.close()
print('----end-----')
po.join()

如果有帮助，请设最佳答案

tjuwlb

原因：多进程需要在main函数中运行

解决方法：加main函数，在main中调用

from multiprocessing import Pool


def worker(msg):
    print(msg)


def main():
    po = Pool(10)
    for i in range(0, 10):
        po.apply_async(worker, (i,))
    print('----start----')
    po.close()
    po.join()
    print('----end-----')


if __name__ == "__main__":
    main()

Ootme

tjuwlb 发表于 2020-2-29 11:15
原因：多进程需要在main函数中运行

解决方法：加main函数，在main中调用

大佬厉害..