客户端的两个线程可以使用来自服务器的相同输入流吗？

Question

我正在开发一个Java客户机/服务器应用程序，它有一套非常具体的规则来说明我必须如何开发它。服务器创建一个ClientHandler实例，该实例具有到客户端套接字的输入和输出流，它们之间的任何输入和输出都由客户端GUI中的事件触发。

我现在添加了服务器端的功能，它将定期向所有连接的客户端发送更新（通过将ClientHandlers中创建的每个PrintWriter对象存储在ArrayList 中来完成）。我需要一个等效的客户端机制来处理这些消息，并且被告知这需要在第二个客户端线程中发生，该线程的run()方法使用do...while(true)循环，直到客户端断开连接。

到目前为止，这一切对我来说都是有意义的，我所纠结的是两个线程将不得不共享一个输入流，并且基本上‘忽略’任何不属于它们处理的类型的消息。在我的脑海中，它应该是这样的：

假设来自服务器的每条消息都向所有人发送值为true的boolean，并向单个客户端发送值为false的消息...

Existing Client Thread
//method called from actionPerformed(ActionEvent e)
//handles server response to bid request
public void receiveResponse()
{
    //thread should only process to-specific-client messages
    if (networkInput.nextBoolean() == false)
    {
        //process server response...
    }
}


Second Client-side Thread
//should handle all messages set to all clients
run()
{
    do {
        if (networkInput.nextBoolean() == true)
        {
            //process broadcasted message...
        } while (true);
}

由于它们需要使用相同的输入流，我显然会添加一些synchronized、wait/notifice调用，但一般来说，我在这里要做的是可能的吗？或者尝试从同一输入流读入的两个线程会不会相互干扰太多？

请让我知道你的想法！

谢谢，马克

Answer 1

你可以做到这一点，尽管它将是复杂的测试和得到正确。多少才算“太多”，就看你了。更简单的解决方案是让一个读取线程将消息传递给两个工作线程。

ExecutorService thread1 = Executors.newSingleThreadedExecutors();
ExecutorService thread2 = Executors.newSingleThreadedExecutors();
while(running) {
    Message message = input.readMessage();
    if (message.isTypeOne())
        thread1.submit(() -> process(message));
    else if (message.isTypeTwo())
        thread2.submit(() -> process(message));
    else
        // do something else.
}
thread1.shutdown();
thread2.shutdown();