在python中读取持续更新的列表

Question

我的目标是从python中的列表中读取值，该列表正在由另一个进程不断更新，我试图在这里制作一个最小的工作代码。我有一个在cfg.py中定义为的全局数组

def initialize():
global infrared_frames
global depth_frames
infrared_frames = []
depth_frames = []

从main.py，一个线程在该数组中添加一个随机值，而主线程睡眠10秒，然后从该数组中读取该值。这是代码-

from multiprocessing import Process
import random
import time
import cfg
cfg.initialize()
def update_array():
while True:
cfg.infrared_frames.append(random.random())
p1 = Process(target=update_array)
p1.start()
time.sleep(10)
print('starting to read array')
print(cfg.infrared_frames)
for a in cfg.infrared_frames:
print(a)

不幸的是，当我尝试在循环之前和time.sleep()调用之后打印数组时，数组仍然是空的，但p1进程正在运行。为什么我不能读取数组？很抱歉，如果这是一个简单的问题，当涉及到python中的线程时，我的知识是有限的提前谢谢。T

Answer 1

在多处理中添加和使用数据的一个好方法是使用Queue。

一个最小的工作示例：

import time
import multiprocessing as mp
from multiprocessing.queues import Queue

def fill_queue(queue):
""" Endless process that fills the queue"""
task = 0
while True:
time.sleep(1)
queue.put(task)
print(f"Added task {task}")
task += 1

def read_queue(queue):
""" Endless process that reads from the queue """
while True:
if queue.empty():
time.sleep(0.2)
else:
print(f"Handling task: {queue.get()}")

if __name__ == '__main__':
queue = Queue(maxsize=-1, ctx=mp.get_context())
task_fill_queue = mp.Process(target=fill_queue, args=(queue,))
task_fill_queue.start()
read_queue(queue)

解释

fill_queue函数保持每秒向队列添加数据。然后由read_queue函数处理。它将每隔0.2秒检查一次队列中的新项目。