套接字线程和 PyGTK

Question

我正在尝试编写一个即时消息程序，基本的用户界面即将完成，我正在研究消息的接收部分。我有一个 UI 类和一个线程 Receive_Socket 类。每次 Received_Socket 类的套接字接收到消息时，它都会执行 gobject.idle_add() 来调用 UI 方法，以便将消息显示到聊天窗口中。在 gobject.idle.add() 行之后，我有一个 while 循环，该循环一直循环直到消息实际上显示在聊天窗口中（我希望在接收另一条消息之前显示该消息，因为我读到了 gobject.idle_add()不保证执行顺序，当然我希望消息按顺序显示:)）

我尝试总结我的代码：

UI类：

Class UI:
##### somewhere in the init #####
    self.message_status = 0
def chat_window(self, contact, message=0):
    Check if a chat window is opened for the contact, if not it opens one.
    => In reality this check if a gtk.Window containing a gtk.Notebook is opened, 
    => if not it opens one
    => Then it creates a page for the contact in the notebook, containing a 
    => gtk.Textview which displays messages
    if message:
        self.message_display(contact, message)
def message_display(self,a,b):
    => Display the message in the message in the contact's textview
    self.message_status = 1

Threaded Receive_Socket类：

Class Receive_Socket(threading.thread):
    message = sock.recv(1024)
    => the sender name is written in the message 
    if message:
        gobject.idle_add(myui.chat_window,sender, message)
        while not myui.message_status:
            time.sleep(0.1)
        myui.message_status = 0

主要代码：

if __name__ == "__main__":
    myui = UI()
    reception = Receive_Socket()
    reception.start()
    gtk.main()

我的问题：

1）这种代码看起来高效吗？它（拥有一个线程接收类和我的 UI 类）是继续的最佳方法吗？

2）当消息显示时，socket可能已经收到了2条或更多消息，因此当再次执行message = sock.recv(1024)时，多条消息将连接到变量message中。我考虑在每条消息中包含消息长度，因此如果 1024 字节中有超过 1 条消息，它将获取该消息并将其余消息放入 message_buffer 变量中，并在再次执行 sock.recv(1024) 之前检查是否message_buffer 变量包含任何内容，如果是，则将 message_buffer 放入 message 变量中，而不是 sock.recv(1024)。有没有更简单/更好的解决方案来做到这一点？

提前致谢，

诺尔希安

Answer 1

1. 没有。不要使用线程。相反，使用 glib.io_add_watch 使 gtk/glib 本身在套接字准备好读取时调用您的函数。这样你就不会冻结你的图形用户界面并且不需要线程。您也不需要 idle_add。

2. 如果您执行1，则不会出现此问题，因为消息将按顺序到达，并且不会出现并发线程来混淆数据。