久久r热视频,国产午夜精品一区二区三区视频,亚洲精品自拍偷拍,欧美日韩精品二区

您的位置:首頁技術(shù)文章
文章詳情頁

有什么方法可以使用java.nio。*在不關(guān)閉套接字的情況下中斷InputStream#read()?

瀏覽:151日期:2024-05-02 14:54:46
如何解決有什么方法可以使用java.nio。*在不關(guān)閉套接字的情況下中斷InputStream#read()??

如果在讀取過程中中斷了InterruptibleChannel,它將被關(guān)閉并拋出ClosedByInterruptException。如果您只想讀取超時(shí),請不要使用任何通道,而只需使用常規(guī)的Socket;用較短的超時(shí)調(diào)用Socket.setSoTimeout(),并在每次超時(shí)觸發(fā)時(shí)檢查線程的isInterrupted()狀態(tài)。更好的是,查看中斷線程的要求。那個(gè)有什么用途?

解決方法

您是否知道在InputStream不關(guān)閉關(guān)聯(lián)套接字的情況下中斷Java讀取的方法?

這是獲取套接字輸入流并轉(zhuǎn)換為可中斷的DataInputStream的當(dāng)前構(gòu)造策略:

InputStream interruptibleInputStream = Channels.newInputStream(Channels.newChannel(m_ConnectionData.getSocket().getInputStream()));DataInputStream myInterruptibleDIS = new DataInputStream(interruptibleInputStream);

這利用ReadableByteChannel提供了read(ByteBuffer)對ClosedByInterruptExceptionthrowable的支持的方法的a。

問題在于,在線程上調(diào)用中斷再在原因read()上調(diào)用DataInputStream會(huì)導(dǎo)致底層套接字被關(guān)閉。

就我而言,我需要使套接字保持打開狀態(tài)。該read呼叫正在等待即將到來的用戶輸入,因此我正在使用中斷將控制權(quán)傳遞回更高的組件,然后最終read再次返回。

如果有人可以提出一種使用JDK內(nèi)置類實(shí)現(xiàn)此目標(biāo)的方法,或者指出某些信息是不可能的,我將不勝感激。

我知道還有其他方法可以達(dá)到相同的效果,但是我很想知道這種方法是否可行。

標(biāo)簽: java
相關(guān)文章:
主站蜘蛛池模板: 栾城县| 界首市| 白河县| 陵水| 泸溪县| 华宁县| 中牟县| 金秀| 横山县| 旌德县| 读书| 会同县| 沛县| 通江县| 交城县| 漯河市| 静乐县| 南丹县| 鲜城| 囊谦县| 巴林左旗| 鹤山市| 寿阳县| 林口县| 贵溪市| 新野县| 淮南市| 濮阳市| 阳东县| 沂南县| 海门市| 龙井市| 乌拉特后旗| 安陆市| 青州市| 石家庄市| 叶城县| 安龙县| 岳西县| 景宁| 那坡县|