JAVA如何取消read方法阻塞

167次閱讀

共計 1494 個字符，預計需要花費 4 分鐘才能閱讀完成。

Java 中的 read 方法通常是指 InputStream 類中的 read 方法，該方法用于從輸入流中讀取數據。當沒有可讀取的數據時，read 方法會阻塞等待數據的到達。如果需要取消 read 方法的阻塞，可以通過以下幾種方式實現：

設置輸入流的超時時間：可以使用 InputStream 的子類如 SocketInputStream、FileInputStream 的 setSoTimeout 方法來設置超時時間。在超過設定的超時時間后，read 方法會拋出 SocketTimeoutException 或 IOException 異常，可以捕獲該異常來取消阻塞。

InputStream inputStream = socket.getInputStream();
inputStream.setSoTimeout(5000); // 設置超時時間為 5 秒 
try {int data = inputStream.read();
    // 讀取數據 
} catch (SocketTimeoutException e) {// 超時處理 
} catch (IOException e) {// IO 異常處理 
}

使用非阻塞 IO：可以使用 NIO（New IO）提供的 Channel 和 Selector 來實現非阻塞的讀取操作。Channel 類提供了非阻塞的 read 方法，可以通過 Selector 類來監聽多個 Channel 的讀就緒事件。

Selector selector = Selector.open();
SocketChannel socketChannel = SocketChannel.open();
socketChannel.configureBlocking(false); // 設置為非阻塞模式 
socketChannel.register(selector, SelectionKey.OP_READ); // 注冊讀就緒事件 
selector.select(5000); // 設置超時時間為 5 秒 
Set<SelectionKey> selectedKeys = selector.selectedKeys();
if (selectedKeys.isEmpty()) {// 超時處理 
} else {Iterator<SelectionKey> iterator = selectedKeys.iterator();
    while (iterator.hasNext()) {SelectionKey key = iterator.next();
        if (key.isReadable()) {SocketChannel channel = (SocketChannel) key.channel();
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            channel.read(buffer);
            // 讀取數據 
        }
        iterator.remove();}
}

使用線程中斷：可以將讀取輸入流的過程放在一個單獨的線程中，在需要取消阻塞的時候調用線程的 interrupt 方法來中斷線程，從而取消阻塞。

Thread readThread = new Thread(() -> {try {while (!Thread.currentThread().isInterrupted()) {int data = inputStream.read();
            // 讀取數據 
        }
    } catch (IOException e) {// IO 異常處理 
    }
});
readThread.start();

// 取消阻塞 
readThread.interrupt();