[已解决]多进程问题求助~~

Python3005

1. import multiprocessing as mp
   
2. import time
   
3. 
   
4. def test(num, value):
   
5.     time.sleep(1)
   
6.     value.value += num
   
7.     print(value.value)
   
8. 
   
9. def multip():
   
10.     value =mp.Value('i')
    
11.     pool = mp.Pool()
    
12.     for each in range(32):
    
13.         pool.apply_async(func = test, args =(each, value))
    
14.     pool.close()
    
15.     pool.join()
    
16.     return value.value

复制代码

请问1：为何print命令不起作用？
2：value.value最后返回的是0，为何没有叠加？

最佳答案

月排行榜 / 总排行榜

ba21

2020-3-10 20:08:20

进程池内存共享数据使用 Manager吧。

1. from multiprocessing import Pool,Manager
   
2. 
   
3. def Func1(a):
   
4.     a.value += 1
   
5.     print(a.value)
   
6. 
   
7. 
   
8. if __name__ == '__main__':
   
9.     manager = Manager()
   
10.     num = manager.Value('i', 1)
    
11.     pool = Pool()
    
12.     for each in range(32):
    
13.         pool.apply_async(func = Func1, args =(num,))
    
14.     pool.close()
    
15.     pool.join()
    
16. 
    
17.     print (num.value)
    
18.     input()
    
19. 
    

复制代码

跳转到最佳答案楼层

lixiangyv

您写了这些函数没有去调用......

Python3005

lixiangyv 发表于 2020-3-10 18:50
您写了这些函数没有去调用......

调用这个multip()

ba21

value =mp.Value('i') #全局的，不用传参，传参进不行

多进程一定要使用
if __name__== "__main__":

直接点击运行.py文件才能看到结果。

°蓝鲤歌蓝

楼上说的没问题，但是这个程序就算加上了楼上说的也不会有结果，你这里不应该使用 Pool，而应该使用 Proces。
在官方文档里，多进程 共享内存 是使用 Process 来实现的。

ba21

进程池内存共享数据使用 Manager吧。

1. from multiprocessing import Pool,Manager
   
2. 
   
3. def Func1(a):
   
4.     a.value += 1
   
5.     print(a.value)
   
6. 
   
7. 
   
8. if __name__ == '__main__':
   
9.     manager = Manager()
   
10.     num = manager.Value('i', 1)
    
11.     pool = Pool()
    
12.     for each in range(32):
    
13.         pool.apply_async(func = Func1, args =(num,))
    
14.     pool.close()
    
15.     pool.join()
    
16. 
    
17.     print (num.value)
    
18.     input()
    
19. 
    

复制代码

Python3005

ba21 发表于 2020-3-10 20:08
进程池内存共享数据使用 Manager吧。

多谢大佬！还想请问Manager.Value 和multiprocessing.Value 有啥区别？

ba21

Python3005 发表于 2020-3-11 00:30
多谢大佬！还想请问Manager.Value 和multiprocessing.Value 有啥区别？

从文档来看multiprocessing.Value是一个主进程传进进程2，等进程2出来；再才能再给进程3 .....
Manager.Value多进程同时共享。