当一个函数从另一个函数收集数据时,如何在python中并行运行两个函数?

这应该说明一些概念。队列用于在进程之间传递对象。

读取器只需在某处获取其值并将其放置在队列中。

写入程序将永远监听队列。 添加“终止”信号是一种非常简单的方法,可以告诉作者永远停止倾听(还有其他更有效的方法使用信号和事件,但这只是说明了这个概念)。

最后,我们“连接”这两个进程,以确保它们在退出主进程之前退出(否则它们将在空间和时间上悬而未决)

from multiprocessing import Process, Queue
from time import sleep

def reader(q):
    for i in range(10):
        print("Reading", i)
        q.put(i)
        sleep(1)
    print("Reading TERMINATED")
    q.put("TERMINATE")


def writer(q):
    while True:
        i = q.get()
        if i == "TERMINATE":
            print("Writer TERMINATED")
            break
        print("Writing", i)

q = Queue()

pr = Process(target=reader, args=(q,))

pw = Process(target=writer, args=(q,))

pw.start()

pr.start()

pw.join()
pr.join()