有什么方法可以使用java.nio。*在不关闭套接字的情况下中断InputStream#read()?
如果在读取过程中中断了InterruptibleChannel,它将被关闭并抛出ClosedByInterruptException。如果您只想读取超时,请不要使用任何通道,而只需使用常规的Socket;用较短的超时调用Socket.setSoTimeout(),并在每次超时触发时检查线程的isInterrupted()状态。更好的是,查看中断线程的要求。那个有什么用途?
解决方法您是否知道在InputStream不关闭关联套接字的情况下中断Java读取的方法?
这是获取套接字输入流并转换为可中断的DataInputStream的当前构造策略:
InputStream interruptibleInputStream = Channels.newInputStream(Channels.newChannel(m_ConnectionData.getSocket().getInputStream()));DataInputStream myInterruptibleDIS = new DataInputStream(interruptibleInputStream);
这利用ReadableByteChannel提供了read(ByteBuffer)对ClosedByInterruptExceptionthrowable的支持的方法的a。
问题在于,在线程上调用中断再在原因read()上调用DataInputStream会导致底层套接字被关闭。
就我而言,我需要使套接字保持打开状态。该read呼叫正在等待即将到来的用户输入,因此我正在使用中断将控制权传递回更高的组件,然后最终read再次返回。
如果有人可以提出一种使用JDK内置类实现此目标的方法,或者指出某些信息是不可能的,我将不胜感激。
我知道还有其他方法可以达到相同的效果,但是我很想知道这种方法是否可行。
相关文章:
1. java - Spring boot启动时报错?2. angular.js - 有没有不需要先git clone xxxx的angular2的教程?3. php - C语言算法题-开灯问题 代码有点看不懂求大神指点?4. java - 当在子类中声明一个父类中存在的变量后,自动调用的父类构造函数不起作用。5. docker-remote-api - docker 有哪些Web管理UI6. 用Java写发送邮件的程序,经常被当做垃圾邮件处理怎么解决7. a标签将 display 设置为 block 后,其内部内容无法将a标签宽度撑开8. node.js - mongodb启动的问题9. android - recyclerview显示错乱10. angular.js - 报这个错是什么原因呢?没有显示,因为报错,可是controller里没有这个错