有什么方法可以使用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內置類實現此目標的方法,或者指出某些信息是不可能的,我將不勝感激。
我知道還有其他方法可以達到相同的效果,但是我很想知道這種方法是否可行。
相關文章:
