为什么进程间无法实现通信。

Question

我使用queue进行进程间的通信，但是put进去的数据在另一个进程中接收不到

class Control_system(QMainWindow, Ui_Control_system):
     socketQueue = multiprocessing.Queue()
     def __init__(self, parent=None):
        super().__init__(parent)
        self.setupUi(self)
        self.p1 = multiprocessing.Process(target=Control_system.connect, args=(self.socketQueue,))
        self.p1.start()
        self.p3 = multiprocessing.Process(target=Control_system.client, args=(self.socketQueue,))
        self.p3.start()

    @staticmethod
    def connect(queue):
        ip_port = ("192.168.1.251", 8880)
        s = socketserver.ThreadingTCPServer(ip_port, MyServer)
        s.serve_forever()

    def client(self):
        print(Control_system.socketQueue.qsize())
#   这里的值还是0

class MyServer(socketserver.BaseRequestHandler):

    def handle(self):
        print("conn is :", self.request)  # conn
        print("addr is :", self.client_address)  # addr

        a[self.client_address] = self.request
        print("a:",a)
        Control_system.socketQueue.put(a)
#   这里的a是放进去的


if __name__ == '__main__':

    if not QApplication.instance():
        app = QApplication(sys.argv)
    else:
        app = QApplication.instance() 

    w = Control_system()
    w.show()
    sys.exit(app.exec())

Answer 1

你需要调用 下信号函数Qtcore.pyqtSigal()，用于两个窗口之间的数据传递。
可以参考以下帖子
https://blog.csdn.net/yuzipeng/article/details/99684935