如何將其他進行中的流式處理器線程擱置

Question

例如，如果我嘗試在服務器程序上構建文件傳輸機制，以便通過利用其自己現有的連接套接字來將發件人A的一個文件字節從用戶B中刪除，能避免它與所有正在進行的聊天流進來的，即保持清醒的等待和除了建立在服務器端額外的ServerSocket這兩個線程之間通知交織......

非常感謝 千電子伏

Answer 1

創建一個消息協議爲您的應用程序區分各種消息類型。然後創建一個「文件塊」消息和一個「聊天」消息以及您需要的任何其他消息。

僞代碼：

經由多個`Socket`s

// sending method 
public synchronized void send(Message msg) { 
    // write message to socket ... 
} 

// receiving method 
while(true) { 
    Message msg = readMessage(); // read message from socket 
    handleMessage(msg); // may want to push this work to another thread 
}