线程中断未结束对输入流的读取的阻塞调用

Question

我正在使用RXTX从串行端口读取数据。读取是在以下列方式产生的线程中完成的：

CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(port);
CommPort comm = portIdentifier.open("Whatever", 2000);
SerialPort serial = (SerialPort)comm;
...settings
Thread t = new Thread(new SerialReader(serial.getInputStream()));
t.start();

SerialReader类实现Runnable并无限期地循环，从端口读取并将数据构造为有用的程序包，然后再将其发送给其他应用程序。但是，我将其简化为以下简单性：

public void run() {
  ReadableByteChannel byteChan = Channels.newChannel(in); //in = InputStream passed to SerialReader
  ByteBuffer buffer = ByteBuffer.allocate(100);
  while (true) {
    try {
      byteChan.read(buffer);
    } catch (Exception e) {
      System.out.println(e);
    }
  }
}

当用户单击停止按钮时，将触发以下功能，从理论上讲，应关闭输入流并突破阻塞的byteChan.read（buffer）调用。代码如下：

public void stop() {
  t.interrupt();
  serial.close();
}

但是，当我运行这段代码时，我永远都不会收到ClosedByInterruptException，一旦输入流关闭，就应该触发该异常。此外，执行会阻塞对serial.close（）的调用-
因为基础输入流仍在读取调用上受阻。我尝试用byteChan.close（）替换中断调用，这将随后导致AsynchronousCloseException，但是，我得到的结果相同。

我所缺少的任何帮助将不胜感激。

Answer 1

RXTX
SerialInputStream（serial.getInputStream（）调用返回的结果）支持一种超时方案，该方案最终解决了我所有的问题。在创建新的SerialReader对象之前添加以下内容将导致读取不再无限期地阻塞：

serial.enableReceiveTimeout(1000);

在SerialReader对象中，我不得不更改一些内容以直接从InputStream读取而不是创建ReadableByteChannel，但是现在，我可以停止并重新启动阅读器而不会出现问题。