java多线程两个线程尝试同时从同一对象输入流中读取对象（）

Question

我尝试制作纸牌游戏。我遇到了线程问题。我只构造了一次objectinputstream，然后只是将它的引用发送给另一个线程，两个线程尝试同时从同一个objectinputstream 中读取一个对象。同样的问题是java.io.StreamCorruptedException: invalid type code: 00，但它没有解决。

客户端服务线程：

    while (true) {
        try {
            Message message = (Message) in.readObject();
            handleClientMessage(message);
            if (message.getType() == Message.messageType.ClientDisconnect) {
                break;
            }
        } catch (IOException ex) {
            Logger.getLogger(ClientServiceThread.class.getName()).log(Level.SEVERE, null, ex);
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(ClientServiceThread.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

游戏线程

public void run() {
    startGame();

    while (true) {
        try {
            Message msg = (Message) inPlayer1.readObject();
            handlePlayerMessage(msg);
        } catch (IOException ex) {
            Logger.getLogger(Game.class.getName()).log(Level.SEVERE, null, ex);
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(Game.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

在和inplayer1相同的objectinputstream。我得到一个异常：java.io.StreamCorruptedException：无效类型代码：00。两个类做不同的工作只有这部分是相似的。请告诉我如何解决这个问题。是有什么办法吗？

Answer 1

只有一个线程读取流并为每个对象做所有需要做的事情。

此线程可以完成两个线程的所有工作和/或您可以在线程之间发送消息以让其他线程完成额外的工作。

Answer 2

如果ObjectInputStream 只被构造一次，然后只是将它的引用传递给另一个线程，那么只需将这个对象的访问权限包含在synchronized 块中，以确保一次只有一个线程可以访问这个对象.

---

假设：in 和 inPlayer1 都表示同一个对象，实际上是 ObjectInputStream，并在不同线程之间共享。

客户端服务线程：

... 
Message message = null;
synchronized (in) {
    message = (Message) in.readObject();
}
...

游戏主题：

... 
Message msg = null;
synchronized (inPlayer1) {
    msg = (Message) inPlayer1.readObject();
}
...