多处理连接后打印全局变量

Question

看起来很简单，但我不明白为什么它不起作用。

#!/usr/bin/env python                        
from multiprocessing import Lock, Process
blah = 0
lock = Lock()

def increment():
    lock.acquire()
    global blah
    blah = blah + 1
    print(blah)
    lock.release()

threads = list()
for i in range(0, 3):
    threads.append(Process(target=increment))

for thread in threads:
    thread.start()

for thread in threads:                       
    thread.join()

print("blah = " + str(blah))

我期待：

1
2
3
blah: 3

但是，我收到：

1
1
1
blah: 0

希望有人能启发我并解释这里发生了什么以及为什么我没有收到我期望的输出。提前致谢！ PS：我在 Cygwin 中使用 Python 2.7.14 运行它

Answer 1

Python 多处理使用独立的进程，它们不共享内存。所以每个进程都有自己的全局实例。

您将需要使用 multiprocessing.Value。

#!/usr/bin/env python                        
from multiprocessing import Process, Value

def increment(blah):
    blah.value = blah.value + 1
    print(blah.value)

if __name__ == '__main__':

    blah = Value('i', 0)
    threads = list()
    for i in range(0, 3):
        threads.append(Process(target=increment, args=[blah]))

    for thread in threads:
        thread.start()

    for thread in threads:                       
        thread.join()

    print("blah = " + str(blah.value))