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

Python3005

import multiprocessing as mp
import time

def test(num, value):
    time.sleep(1)
    value.value += num
    print(value.value)

def multip():
    value =mp.Value('i')
    pool = mp.Pool()
    for each in range(32):
        pool.apply_async(func = test, args =(each, value))
    pool.close()
    pool.join()
    return value.value

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

最佳答案

月排行榜 / 总排行榜

ba21

2020-3-10 20:08:20

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

from multiprocessing import Pool,Manager

def Func1(a):
    a.value += 1
    print(a.value)


if __name__ == '__main__':
    manager = Manager()
    num = manager.Value('i', 1) 
    pool = Pool()
    for each in range(32):
        pool.apply_async(func = Func1, args =(num,))
    pool.close()
    pool.join()

    print (num.value)
    input()

跳转到最佳答案楼层

lixiangyv

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

Python3005

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

调用这个multip()

ba21

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

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

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

°蓝鲤歌蓝

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

ba21

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

from multiprocessing import Pool,Manager

def Func1(a):
    a.value += 1
    print(a.value)


if __name__ == '__main__':
    manager = Manager()
    num = manager.Value('i', 1) 
    pool = Pool()
    for each in range(32):
        pool.apply_async(func = Func1, args =(num,))
    pool.close()
    pool.join()

    print (num.value)
    input()

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多进程同时共享。