5.管道 Pipe

/*管道（Pipe）*/

　　Java NIO 管道是 /*2 个线程*/ 之间的 /*单向*/数据连接

　　Pipe 有一个 source 通道和一个 sink 通道。数据会被写到 sink 通道，从source通道读取

　　Thread A ---> SinkChannel(Pipe) ---> SourceChannel(Pipe) ---> Thread B

//从管道读取数据（访问source通道）

SourceChannel sourceChannel = pipe.source();

//调用source通道的 read() 方法来读取数据

ByteBuffer buffer = ByteBuffer.allocate(1024);

sourceChannel.read(buf);

 public class TestPipe {

     @Test

     public void test1() throws Exception {

         // 1.获取管道

         Pipe pipe = Pipe.open();

         // 2.将缓冲区 中的数据写入管道   (线程A)

         ByteBuffer buffer = ByteBuffer.allocate(1024);

         SinkChannel sinkChannel = pipe.sink();

         buffer.put("通过单向管道发送数据".getBytes());

         buffer.flip();

         sinkChannel.write(buffer);

         // 3.读取缓冲区中的数据   (线程B)

         SourceChannel sourceChannel = pipe.source();

         sourceChannel.read(buffer);

         buffer.flip();

         System.out.println(new String(buffer.array()));

         sourceChannel.close();

         sinkChannel.close();

     }

 }

巴特西

5.管道 Pipe

最新文章

热门文章