java - 如何关闭 2 个线程使用的 inputStream

Question

我有 2 个线程 - 一个是接收消息，第二个是接收和发送。

PrintStream os = new PrintStream(sock.getOutputStream());
BufferedReader is = new BufferedReader(new InputStreamReader(sock.getInputStream()));

ServerThread server = new ServerThread(sock, maxid, os,is);
OutputThread out = new OutputThread(sock, maxid, os,is);

然后，当我关闭连接时，我想正确关闭 is 和 os，但是如何在 2 个线程中同时完成呢？我java.net.SocketException进去ServerThread

public ServerThread(..){
    try{
          //here I use is and os

} finally {
        disconnect();
    }
}

public void disconnect() {
    try {
        System.out.println(addr.getHostName()+ " disconnected");
        os.close();
        try {
            is.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    } finally {
        this.interrupt();
    }
}

Answer 1

您的线程正在从外部来源接收 is 和 os，因此关闭流的责任应由外部实体承担。不要在螺纹内关闭它们。在创建它们的地方从外部处理它。

Answer 2

查看http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/CyclicBarrier.html 这可用于线程在其中一个关闭流之前相互等待。