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

Ootme

1. from multiprocessing import Pool
   
2. 
   
3. 
   
4. def worker(msg):
   
5.     print(msg)
   
6. 
   
7. 
   
8. po = Pool(3)
   
9. for i in range(0,10):
   
10.     po.apply_async(worker,(i,))
    
11. 
    
12. 
    
13. print('----start----')
    
14. po.close()
    
15. po.join()
    
16. print('----end-----')
    

复制代码

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

最佳答案

月排行榜 / 总排行榜

tjuwlb

2020-2-29 11:15:22

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

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

1. from multiprocessing import Pool
   
2. 
   
3. 
   
4. def worker(msg):
   
5.     print(msg)
   
6. 
   
7. 
   
8. def main():
   
9.     po = Pool(10)
   
10.     for i in range(0, 10):
    
11.         po.apply_async(worker, (i,))
    
12.     print('----start----')
    
13.     po.close()
    
14.     po.join()
    
15.     print('----end-----')
    
16. 
    
17. 
    
18. if __name__ == "__main__":
    
19.     main()

复制代码

跳转到最佳答案楼层

qiuyouzhi

这样试试：

1. from multiprocessing import Pool
   
2. 
   
3. 
   
4. def worker(msg):
   
5.     print(msg)
   
6. 
   
7. 
   
8. po = Pool(3)
   
9. for i in range(0,10):
   
10.     po.apply_async(worker,(i,))
    
11. 
    
12. 
    
13. print('----start----')
    
14. po.close()
    
15. print('----end-----')
    
16. po.join()

复制代码

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

tjuwlb

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

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

1. from multiprocessing import Pool
   
2. 
   
3. 
   
4. def worker(msg):
   
5.     print(msg)
   
6. 
   
7. 
   
8. def main():
   
9.     po = Pool(10)
   
10.     for i in range(0, 10):
    
11.         po.apply_async(worker, (i,))
    
12.     print('----start----')
    
13.     po.close()
    
14.     po.join()
    
15.     print('----end-----')
    
16. 
    
17. 
    
18. if __name__ == "__main__":
    
19.     main()

复制代码

Ootme

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

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

大佬厉害..