我正在制作一个项目，从客户端传感器收集数据，处理收集到的数据并将其发送回客户端。可能有多个客户端要求同时从我们的服务器接收一些数据，所以我必须实现多重处理。我无法使用线程，因为某些变量必须与客户端无关。如果我这样做，我的代码可能会变得非常难以阅读和升级，而我不希望这样。所以我决定使用Processes，但是现在有一些数据需要在父进程和子进程之间进行剪切。经过一番研究，我发现 Pipe 通信可以满足我的要求。
以下代码成功地将数据从父进程发送到子进程，子进程更新数据并将其发送回父进程。但它之所以起作用只是因为 sleep() 函数阻止父级与子级同时使用管道。
如何更改它以使其执行相同的操作，但没有 sleep() 函数，我相信它很可能会在将来引起问题？
from multiprocessing import Process, Pipe
import time
def update_data(pipe):
p_out, p_in = pipe
L = []
while True:
message = p_out.recv()
if message=='FINISHED':
break
L.append(message)
L.append(['new data']) #updating received data
writer(L, p_in) #sending received data to parent Process
p_in.close()
def writer(i, p_in):
p_in.send(i)
p_in.send('FINISHED')
L = ['0' for i in range(10)] #current data
if __name__=='__main__':
p_out, p_in = Pipe()
update_data_process = Process(target=update_data, args=((p_out, p_in),))
update_data_process.start()
writer(L, p_in) #sending current data to …