PrintWriter等待刷新()

Question

我正在编写多线程socket服务器。我使用nio的ServerSocketChannel接受连接。然后，我使用bufferedreader和打印写入器(在单独的线程中)对socketChannel进行读写。问题是PrintWriter锁定并等待flush()命令。它会阻塞线程，直到BufferedReader接收到数据。

Answer 1

这表明接收器读取速度很慢。这就是阻塞I/O的工作原理。如果你想要非阻塞的I/O，你已经在实现这个目标了，因为你已经在使用NIO了。尽管我真的看不出在阻塞模式下使用NIO的意义。

Answer 2

正如@EJP所说，这基本上就是阻塞IO的工作方式。事实上，这个问题在任何有生产者和消费者的架构中都是固有的。如果生产者生产的东西(在本例中是文本输出行)的速度超过了消费者的消费速度，那么生产者最终必须阻止它。

你怎么解决这个问题呢？首先是一些一般性的东西。

如果生产商生产产品的速度比消费者长期消费的速度快，你就进退两难了。您必须降低生产者的生产率，加快消费者的消耗率，或者减少管道中的管理费用以达到同样的效果。其他方法都不起作用。

如果速率不匹配只是暂时的，您可以通过向流水线添加一些额外的缓冲来“掩盖裂缝”。如果两者之间的连接具有一定的缓冲能力，则可以增加它。或者，您可以在生产者或消费者端添加额外的缓冲。

这里有一些在你的特殊情况下可能会有帮助的东西。

• 减少你在生产者线程中编写的内容。
• 在消费者线程中做的工作更少，或者分析/调整它们以更快地完成工作。
• 不使用套接字在同一个JVM中的两个线程之间进行通信。如果您可以安排它，请使用Java PipeInputStream / PipeOutputStream对，或者使用您自己的等价物。(如果您使用套接字，则读取和写入涉及系统调用、将数据复制到内核缓冲区和从内核缓冲区复制数据等操作。)
• 在通信必须在JVM之外进行的情况下，请确保对基础流使用Buffered*包装器，以减少读取/写入时进行的系统调用的数量。