如何在不同进程之间共享字典中的更新值？

Question

我是这里的新手，也是 Python 的新手。我有一个关于字典和多处理的问题。我想运行我的 Raspberry Pi 第二个核心上的这部分代码（第一个是运行ning GUI 应用程序）。因此，我创建了一个字典（keys(20) + 每个键的长度为 256 的数组——下面的脚本只是一个简短的例子）。我在一个单独的脚本中初始化了这个字典，并将这个字典中的所有值都置为零。脚本 table1.py（这本词典应该可以从两个核心获得）

diction = {}
diction['FrameID']= [0]*10
diction['Flag']= ["Z"]*10

在第二个脚本中（应该运行在第二个核心上），我读取了我从串口获得的值并put/set他们在这个字典（解析+转换）中根据合适的地方。由于我通过串口获取了很多信息，信息一直在变化。脚本 Readmode.py

from multiprocessing import Process
import time
import serial
import table1

def replace_all(text, dic):
for i, j in dic.iteritems():
    text = text.replace(i, j)
return text
def hexTobin(hex_num):
scale = 16 ## equals to hexadecimal
num_of_bits = len(hex_num)*4
bin_num = bin(int(hex_num, scale))[2:].zfill(num_of_bits) #hex to binary
return bin_num

def readSerial():
port = "/dev/ttyAMA0"
baudrate = 115200
ser = serial.Serial(port, baudrate, bytesize=8, parity=serial.PARITY_NONE, stopbits=1, xonxoff=False, rtscts=False)
line = []
for x in xrange(1):
    ser.write(":AAFF:AA\r\n:F1\r\n")        # new           
    while True:
        for c in ser.read():
            line.append(c)
            a=''.join(line[-2:])
            if a == '\r\n':
                b=''.join(line)
                print("what I get:" + b) 
                c=b[b.rfind(":"):len(b)] #string between last ":" start delimiter and stop delimiter
                reps = {':':'', '\r\n':''} #throw away start and stop delimiter
                txt = replace_all(c, reps)   
                print("hex num: " + txt) 
                bina_num=hexTobin(txt) # convert hex to bin
                print("bin num: " + bina_num)
                ssbit = bina_num[:3] # first three bits 
                print("select first three bits: " + ssbit)
                abit=int(ssbit,2) # binary to integer 
                if abit == 5:
                    table1.diction['FrameID'][0]=abit
                    if abit == 7:
                        table1.diction['FrameID'][5]=abit         
                        print("int num: ",abit)
                        print(table1.diction)
                        line = []
                        break
                        ser.close()

p1=Process(target=readSerial)
p1.start()

那段时间我想阅读这本词典中的信息并在另一个过程中使用它们。但是当我尝试读取这些值时，它们都是零。

我的问题是如何创建一个可用于两个进程并且可以根据从串行端口获取的数据进行更新的字典？预先感谢您的回答。

Answer 1

在Python中，当你启动两个不同的脚本时，即使它们导入了一些公共模块，它们也没有任何共享（代码除外）。如果两个脚本都 import table1，那么它们都有自己的 table1 模块实例，因此它们都有自己的 table1.diction 变量实例。

如果你仔细想想，不得不那样。否则所有 Python 脚本将共享相同的 sys.stdout，例如。因此，同时执行的两个不同脚本之间或多或少没有共享任何内容。

multiprocessing 模块允许您从同一个脚本创建多个进程。因此，您需要将 GUI 和阅读功能合并到同一个脚本中。但是你可以做你想做的。您的代码将如下所示：

import multiprocessing

# create shared dictionary sd

p1=Process(target=readSerial, args = (sd,)
p1.start()

# create the GUI behaviour you want

但请稍等。这也行不通。因为当 Process 创建时，它会启动一个新的 Python 解释器实例并再次创建它自己的所有实例，就像启动一个新脚本一样。所以即使现在，默认，readSerial 中的任何内容都不会与 GUI 进程共享。

但幸运的是 multiprocessing 模块提供了一些明确的技术来在进程之间共享数据。有不止一种方法可以做到这一点，但这是一种有效的方法：

import multiprocessing
import time

def readSerial(d):
    d["test"] = []
    for i in range(100):
        l = d["test"]
        l.append(i)
        d["test"] = l
        time.sleep(1)

def doGUI(d):
    while True:
        print(d)
        time.sleep(.5)


if __name__ == '__main__':
    with multiprocessing.Manager() as manager:
        sd = manager.dict()

        p = multiprocessing.Process(target=readSerial, args=(sd,))
        p.start()

        doGUI(sd)

您会注意到 readSerial 函数中对列表的追加有点奇怪。那是因为我们在这里使用的字典对象不是普通的字典。它实际上是一个字典proxy，它隐藏了一个用于在两个进程之间发送数据的管道。当我附加到字典中的列表时，需要通知代理（通过分配给字典）以便它知道通过管道发送更新的数据。这就是为什么我们需要赋值（而不是简单地直接改变字典中的列表）。有关更多信息，请查看 docs.

如何在不同进程之间共享字典中的更新值？

How can I share an updated values in dictionary among different process?

dictionary

serial-port

multiprocessing

python-2.7