如何从单独的进程访问全局变量

Question

我有两个运行在不同内核上的python进程，它们在运行时需要相互通信。目前我可以通过多线程来实现这一点；

import threading
x=0
def a():
global x
if x==100:
pass
#Do something
def b():
global x
while 1:
x=x+1
t1=threading.thread(target=a)
t2=threading.thread(target=b)
t1.start()
t2.start()

但是我想使用multiprocessing模块。有没有什么方法可以使用多处理将上面的代码转换成某种东西？

Answer 1

这里有一个与您原来的示例类似但使用多处理的示例。。。

from multiprocessing import Process, Value
def a(x):
while True:
if x.value == 10:
print('Done.  x = ', x.value) 
break
def b(x):
for _ in range(10):
x.value += 1
x = Value('i', 0)   # integer with initial value of 0
t1=Process(target=a, args=(x,))
t2=Process(target=b, args=(x,))
t1.start()
t2.start()

请注意，虽然我确实将x作为参数传递给了函数，但如果您只是将其作为全局使用，就像上面所说的那样，这看起来仍然有效。这里真正的技巧是使用multiprocessing.Value对象并使用x.value访问它。