我正在使用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(缓冲)调用.代码如下：

public void stop() {

t.interrupt();

serial.close();

}

但是,当我运行此代码时,我从未得到ClosedByInterruptException,一旦输入流关闭,它应该触发.此外,执行阻止调用serial.close() – 因为底层输入流仍然在读取调用上阻塞.我已经尝试用byteChan.close()替换中断调用,然后应该导致AsynchronousCloseException,但是,我得到了相同的结果.

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

解决方法:

您不能简单地通过包装它来将不支持可中断I / O的流创建到InterruptibleChannel中(并且,无论如何,ReadableByteChannel不会扩展InterruptibleChannel).

您必须查看基础InputStream的合约. SerialPort.getInputStream()对其结果的可中断性有何评价？如果它没有说什么,你应该假设它忽略了中断.

对于任何未明确支持可中断性的I / O,唯一的选择通常是从另一个线程关闭流.这可能会立即引发在调用流时阻塞的线程中的IOException(尽管它可能不是AsynchronousCloseException).

但是,即使这非常依赖于InputStream的实现 – 底层操作系统也是一个因素.

请注意newChannel()返回的ReadableByteChannelImpl类的源代码注释：

private static class ReadableByteChannelImpl

extends AbstractInterruptibleChannel // Not really interruptible

implements ReadableByteChannel

{

InputStream in;

⋮

标签：java,multithreading,channel,nonblocking,rxtx

来源： https://codeday.me/bug/20191006/1861802.html