python - 如何在python中同时运行两个同步进程

Question

让两个进程function1、function2同时运行。function1//连续追加列表function2//从 function1 获取列表并获取列表中的所有数据并复制到另一个列表，刷新原始列表并处理复制的列表。

sample code:


list_p =[]
def function1(data):
     list_p.append(data)

def function2(list_p):
      list_q = list_p.copy()
      list_p.flush()
      x= process(list_q)
      return x

while True:
    //coming data continously
    function1(coming data)

那么，如何同时使用 function1 和 function2 ，以便我可以从 function1 获取数据并刷新它(刷新后开始在 function1 中从 0 开始附加索引)此外，同时可以附加列表在函数1中。

同时，function1 可以追加列表，function 2 可以处理新列表，在完成 function2 的处理后，它再次获取 function2 处理时追加的原始列表中的所有数据。

继续..

Answer 1

这是一个使用线程的示例。我在生产者中使用了输入函数来代替数据流。 (它基于 https://techmonger.github.io/55/producer-consumer-python/ 。)

from threading import Thread
from queue import Queue

q = Queue()
final_results = []

def producer():
    while True:
        i = int(input('Give me some number: '))  # here you should get data from data stream
        q.put(i)


def consumer():
    while True:
        number = q.get()
        result = number**2
        final_results.append(result)
        print(final_results)
        q.task_done()

t = Thread(target=consumer)
t.daemon = True
t.start()

producer()