| from multiprocessing import Pipe, Queue | |
| import time | |
| import threading | |
| class PipeSide(object): | |
| def __init__(self, q_2remote, q_2local) -> None: | |
| self.q_2remote = q_2remote | |
| self.q_2local = q_2local | |
| def recv(self): | |
| return self.q_2local.get() | |
| def send(self, buf): | |
| self.q_2remote.put(buf) | |
| def poll(self): | |
| return not self.q_2local.empty() | |
| def create_queue_pipe(): | |
| q_p2c = Queue() | |
| q_c2p = Queue() | |
| pipe_c = PipeSide(q_2local=q_p2c, q_2remote=q_c2p) | |
| pipe_p = PipeSide(q_2local=q_c2p, q_2remote=q_p2c) | |
| return pipe_c, pipe_p | |