Java NIO中的Pipe如何實現線程間通信

Java NIO（New I/O）庫提供了一種非阻塞的I/O操作方式，其中Pipe是一個用于在不同線程之間傳輸數據的通道。Pipe由兩個部分組成：一個SinkChannel（接收端）和一個SourceChannel（發送端）。數據從SourceChannel寫入，然后從SinkChannel讀取。這種機制可以實現線程間的高效通信。

以下是使用Java NIO的Pipe實現線程間通信的步驟：

1. 創建一個Pipe對象：

Pipe pipe = Pipe.open();

2. 獲取SinkChannel和SourceChannel：

SinkChannel sinkChannel = pipe.sink();
SourceChannel sourceChannel = pipe.source();

3. 在發送數據的線程中，將數據寫入SinkChannel：

ByteBuffer buffer = ByteBuffer.allocate(1024);
buffer.put("Hello from sender thread!".getBytes());
buffer.flip(); // 切換為讀模式

while (buffer.hasRemaining()) {
    sinkChannel.write(buffer);
}
sinkChannel.close(); // 關閉SinkChannel，表示數據發送完畢

4. 在接收數據的線程中，從SourceChannel讀取數據：

ByteBuffer buffer = ByteBuffer.allocate(1024);

while (sourceChannel.read(buffer) != -1) {
    buffer.flip(); // 切換為讀模式
    while (buffer.hasRemaining()) {
        System.out.print((char) buffer.get());
    }
    buffer.clear(); // 清空緩沖區，準備接收下一次數據
}

sourceChannel.close(); // 關閉SourceChannel，表示數據接收完畢

注意：在實際應用中，可能需要使用多線程或多路復用器（Selector）來處理多個通道的事件。這種情況下，可以將SinkChannel和SourceChannel注冊到Selector上，并根據需要處理讀寫事件。

總之，Java NIO的Pipe提供了一種簡單的方式來實現在不同線程之間傳輸數據。通過使用SinkChannel和SourceChannel，可以輕松地在發送和接收數據的線程之間進行通信。