多处理中的可变变量

Question

好的，我尝试通过两个不同的进程修改数组的值。我已经阅读了有关使用代理列表的文档，我使用了它，但我不知道为什么它不起作用。

所以1个数组和两个进程同时修改它..

import multiprocessing as mp
from multiprocessing.sharedctypes import Value, Array
import time

def decrement(baris):
    for x in range(0,5):
        c = [x-1 for x in baris]
        baris = Array('i', c)
        print(baris[:])
        time.sleep(1)
    print(baris[:])

def assign(baris):
    for x in range(0,2):
        f = baris[:]
        f[1] = 5
        baris = Array('i',f)
        time.sleep(1)
    print(baris[:])


if __name__ == '__main__':
    baris = Array('i',[10,10,10], lock=mp.Lock())
    decrease = mp.Process(target = decrement, args=(baris,))
    decrease.daemon = True
    decrease.start()
    change = mp.Process(target = assign, args=(baris,))
    change.daemon = True
    change.start()

    decrease.join()
    change.join()

    dir(baris)
    print(baris[:])# + 'Final')

baris 是我希望最终改变的变量。 c 和 f 是代理列表。当进程运行、进程 'assign' 将 baris[1] 的值更改为 5 但进程 'decrement' 没有提及该更改。最后，巴里斯一点都没变！！！！我卡住了，不知道该怎么做，是否有任何可能的方式运行我想要什么？最后我希望我得到 baris = [5,4,5].

如果我的语法错误等，请更正

Answer 1

所以我刚刚测试了我的评论。

import multiprocessing as mp
from multiprocessing.sharedctypes import Array
import time

def decrement(baris):
    for x in range(0,5):
        for i, v in enumerate(baris):
            baris[i] = v - 1
        print(baris[:])
        time.sleep(1)
    print(baris[:])

def assign(baris):
    for x in range(0,2):
        baris[1] = 5
        time.sleep(1)
    print(baris[:])


if __name__ == '__main__':
    baris = Array('i',[10,10,10], lock=mp.Lock())
    decrease = mp.Process(target = decrement, args=(baris,))
    decrease.daemon = True
    decrease.start()
    change = mp.Process(target = assign, args=(baris,))
    change.daemon = True
    change.start()

    decrease.join()
    change.join()

    dir(baris)
    print(baris[:])# + 'Final')

baris 是一个共享指针，当您使用代理列表将其重新分配给它时，您只是在修改正在传递的指针值的本地副本。如果要修改共享值，必须直接对共享值进行赋值。

多处理中的可变变量

Mutable Variable in Multiprocessing

python

mutable

multiprocessing