Slexy.org is shutting down and stopped accepting new Pastes on May 4th, 2021.
Existing Pastes will stop being available on or after May 10th, 2021.
Author: Not specified Language: text
Description: Not specified Timestamp: 2017-07-13 17:38:16 +0000
View raw paste Reply
  1. import java.io.IOException;
  2. import java.io.PipedInputStream;
  3. import java.io.PipedOutputStream;
  4. public class PipeExample
  5. {
  6.         public static void main(String[] args) throws IOException
  7.         {
  8.                 final PipedOutputStream output = new PipedOutputStream();
  9.                 final PipedInputStream  input  = new PipedInputStream(output);
  10.                 Thread thread1 = new Thread(new Runnable()
  11.                 {
  12.                         @Override
  13.                         public void run()
  14.                         {
  15.                                 try
  16.                                 {
  17.                                         output.write("Hello world, pipe!".getBytes());
  18.                                 }
  19.                                 catch (IOException e)
  20.                                 {
  21.                                 }
  22.                         }
  23.                 });
  24.                 Thread thread2 = new Thread(new Runnable()
  25.                 {
  26.                         @Override
  27.                         public void run()
  28.                         {
  29.                                 try
  30.                                 {
  31.                                         int data = input.read();
  32.                                         while(data != -1)
  33.                                         {
  34.                                                 System.out.print((char) data);
  35.                                                 data = input.read();
  36.                                         }
  37.                                 }
  38.                                 catch (IOException e)
  39.                                 {
  40.                                 }
  41.                         }
  42.                 });
  43.                 thread1.start();
  44.                 thread2.start();
  45.         }
  46. }
View raw paste Reply