如何在一个线程中修改变量并在另一个线程中检查它？

Question

下面是演示问题的代码。请注意，这只是一个例子，我在一个更复杂的应用程序中使用相同的逻辑，我不能使用睡眠作为时间量，process1 需要修改变量，取决于速度互联网连接。

from multiprocessing import Process

code = False

def func():
    global code
    code = True

pro = Process(target=func)
pro.start()

while code == False:
    pass

pro.terminate()
pro.join()

print('Done!')

在运行上，屏幕上没有显示任何内容。当我按 CTRL-C 终止程序时，堆栈跟踪显示正在执行 while 循环。

Answer 1

Python 有一些并发库：threading、multiprocessing 和 asyncio（以及更多）。

multiprocessing 是一个使用子进程来绕过 python 无法同时执行运行 CPU 密集型任务的库。要在不同的 multiprocessing.Processes 之间共享变量，请通过 multiprocessing.Manager() 实例创建它们。例如：

import multiprocessing

import time


def func(event):
    print("> func()")
    time.sleep(1)
    print("setting event")
    event.set()
    time.sleep(1)
    print("< func()")


def main():
    print("In main()")

    manager = multiprocessing.Manager()
    event = manager.Event()
    p = multiprocessing.Process(target=func, args=(event,))
    p.start()

    while not event.is_set():
        print("waiting...")
        time.sleep(0.2)

    print("OK! joining func()...")
    p.join()

    print('Done!')


if __name__ == "__main__":
    main()

如何在一个线程中修改变量并在另一个线程中检查它？

How to modify a variable in one thread and check it in another?

python

multiprocessing

race-condition

python-multiprocessing