Java NIO Pipe

Pipe is another channel used for communicate between threads.
It has 2 ends, source for read only, and sink for write only.

Create

Simply use open

Pipe pipe = Pipe.open();

Write

// get the sink/write end of pipe
Pipe.SinkChannel sink = pipe.sink();
String newData = "Rugal Bernstein:" + System.currentTimeMillis();

ByteBuffer buf = ByteBuffer.allocate(48);
buf.clear();
buf.put(newData.getBytes());
buf.flip();

while (buf.hasRemaining()) {
  // same as other channel, just write to it
  sink.write(buf);
}

Read

// get source/read end of pipe
Pipe.SourceChannel source = pipe.source();
buf.clear();
// same as other channel, simply read it into byte buffer
source.read(buf);
System.out.println(new String(buf.array()));