当调用print方法时，printWrit卡住了

Question

这是一个线程，用于处理服务器端的输入和输出：

    public void run() {
        Thread currentThread = Thread.currentThread();
        while (!currentThread.isInterrupted()) {
            SocketChannel socketChannel = null;
            try {
                socketChannel = serverSocketChannel.accept();
                readFromSocket(socketChannel);
            } catch (ClosedByInterruptException e) {
                // closed due to interrupt
                connected = false;
            } catch (IOException e) {
                if (!isInterrupted()) {
                    e.printStackTrace();
                }
                connected = false;
            } finally {
                quietClose(socketChannel);
            }
        }
    }

    /**
     * Reads an message from socketChannel and executes
     * {@link AbstractServer#handleMessage(String)}. Initializes
     * {@link #writer} with the socketChannel.
     * 
     * @param socketChannel
     * @throws IOException
     */
    public void readFromSocket(SocketChannel socketChannel) throws IOException {
        reader = null;
        writer = null;
        try {
            reader = new BufferedReader(new InputStreamReader(socketChannel.socket().getInputStream()));

            if (writer == null) {
                writer = new PrintWriter(socketChannel.socket().getOutputStream(), true);
            }
            String message;
            while ((message = reader.readLine()) != null) {
                handleMessage(message);
            }
        } catch (ClosedByInterruptException e) {
            throw e;
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            quietClose(reader);
            quietClose(writer);
        }
    }

如果我调用print方法，线程就会被阻塞。这意味着“之前”是打印出来的，但“之后”永远不会到达。printwriter的CheckError方法返回false！

    /**
     * Sends a message to the client.
     * 
     * @param message
     */
    public void sendMessage(final String message) {
        System.out.println("before");
        writer.print(message);
        System.out.println("after");
        writer.flush();
    }

它位于一个AbstractServer中，由两个不同的服务器使用。第一个以前就已经使用过了，而且一直都没有问题（现在仍然如此）。另一个是新的，导致了这个问题。对于每个初始化的连接（两个具有不同端口的本地主机），它肯定只有一个写入程序。

客户端数据获取程序如下所示：

protected void fetchDataFromSocket() {
    if (socketDataFetcher != null) {
        socketDataFetcher.interrupt();
    }

    socketDataFetcher = new Thread(new Runnable() {
        @Override
        public void run() {
            while (!Thread.currentThread().isInterrupted()) {
                try {
                    String message = socketConnection.readLine();
                    if (messageHandler != null) {
                        messageHandler.handleMessage(message);
                    }
                } catch (IOException e) {
                    Thread.currentThread().interrupt();
                }
            }
        }
    });
    socketDataFetcher.start();
}

它和另一个几乎一样，只需要很少的改变，实际上不会导致问题。是什么原因导致打印作者这样做的？

编辑：如果我不在客户端启动socketDataFetcher，printwriter就不会被卡住！

Answer 1

虽然我没有看到这些声明，但reader和writer对象（在readFromSocket（）方法中引用）看起来可能是成员变量。我会担心读者和作者不是线程安全的。我会考虑删除这些成员变量，看看你是否仍然与作者有问题。