ObjectInputStream 读线程阻塞 ObjectOutputStream 写线程

Question

我有两个线程，我们称它们为A 和B。 A 不断通过readPacket 函数从ObjectInputStream 中寻找数据包（这将是while(true) 在线程等中）

当A 正在寻找这些数据包时，我希望B 通过writePacket 函数将数据包写入ObjectOutputStream。

但是每当我想这样做时，我都会陷入僵局；我不明白两个不同的函数怎么会互相死锁？

   import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.concurrent.locks.ReentrantLock;

public class ConnectionBay
{
    private Socket connection;
    private ObjectOutputStream output_stream;
    private ObjectInputStream input_stream;

    ConnectionBay(Socket socket) throws IOException{
        this.connection = socket;
        this.output_stream = new ObjectOutputStream(connection.getOutputStream());
        this.output_stream.flush();
        this.output_stream.reset();
        this.input_stream = new ObjectInputStream(connection.getInputStream());
    }
    public synchronized void writePacket(Packet packet) throws IOException{
        this.output_stream.writeObject(packet);
        this.output_stream.flush();
        this.output_stream.reset();
    }
    public synchronized Packet readPacket() throws IOException, ClassNotFoundException{
        return (Packet)this.input_stream.readObject();
    }
}

Answer 1

由于您在 readPacket 和 writePacket 定义中使用了 synchronized 关键字，因此您已经创建了同步方法。如tutorial 中所述，同一对象上同步方法的两次调用不可能交错。在您的情况下，“对象”不是输入或输出流，而是 ConnectionBay 对象。通常，当您想阻止两个线程访问对象中的任何状态时，您会使用同步方法。由于两个流都是单个 ConnectionBay 对象的一部分，并且同步方法阻止当前访问该对象，因此读取和写入之间的死锁正是我所期望的。

根据您的问题 - 听起来您真正想要的是有两个单独的同步 - 一个用于输入流，一个用于输出流。如果是这种情况，我建议使用synchronized statements。下面的示例显示了如何修改 readPacket。

public Packet readPacket() throws IOException, ClassNotFoundException{
    synchronized(this.input_stream) {
        return (Packet)this.input_stream.readObject();
    }
}

如果你采用这种方法（让流本身成为锁），你应该将“input_stream”变量设为final

private final ObjectInputStream input_stream;

这确保您可以安全地使用 input_stream 作为锁，因为它保证在构造后不会更改。

另一种方法是再创建两个变量来充当锁并将它们与流配对。

private ObjectInputStream input_stream;
private final Object input_lock = new Object();
private ObjectOutputStream output_stream;
private final Object output_lock = new Object();

...

public Packet readPacket() throws IOException, ClassNotFoundException{
    synchronized(this.input_lock) {
        return (Packet)this.input_stream.readObject();
    }
}

这种方法更灵活，如果您在连接托架的生命周期内创建和销毁流变量，则可能需要此方法。

不要忘记使用类似的更改来更新您的 writePacket 方法。