Author: Not specified Language: java
Description: Not specified Timestamp: 2017-07-13 17:35:34 +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.             @Override
  12.             public void run() {
  13.                 try {
  14.                     output.write("Hello world, pipe!".getBytes());
  15.                 } catch (IOException e) {
  16.                 }
  17.             }
  18.         });
  19. Thread thread2 = new Thread(new Runnable() {
  20.             @Override
  21.             public void run() {
  22.                 try {
  23.                     int data = input.read();
  24.                     while(data != -1){
  25.                         System.out.print((char) data);
  26.                         data = input.read();
  27.                     }
  28.                 } catch (IOException e) {
  29.                 }
  30.             }
  31.         });
  32. thread1.start();
  33.         thread2.start();
  34. }
  35. }
View raw paste Reply