«Back to Home

Core Java
Topics

PipedInputStream And PipedOutputStream Classes in Java

PipedInputStream and PipedOutputStream classes
 
PipedInputStream and PipedOutputStream classes have a capability to read and write the data at the same time.
 
Both streams are connected with each other with the connect() method of the PipedOutputStream class.
 
Let’s see an example with threads, given below.
 
Code
  1. public class PipedClass {  
  2.     public static void main(String args[]) throws Exception {  
  3.         final PipedOutputStream pos = new PipedOutputStream();  
  4.         final PipedInputStream pis = new PipedInputStream();  
  5.         pos.connect(pis);  
  6.         Thread t1 = new Thread() {  
  7.             public void run() {  
  8.                 for (int i = 1; i <= 10; i++) {  
  9.                     try {  
  10.                         pos.write(i);  
  11.                         Thread.sleep(1500);  
  12.                     } catch (Exception e) {}  
  13.                 }  
  14.             }  
  15.         };  
  16.         Thread t2 = new Thread() {  
  17.             public void run() {  
  18.                 try {  
  19.                     for (int i = 1; i <= 10; i++) {  
  20.                         System.out.println(pis.read());  
  21.                     }  
  22.                 } catch (Exception e) {}  
  23.             }  
  24.         };  
  25.         t1.start();  
  26.         t2.start();  
  27.     }  
  28. }  
35

Output

36

In the example, mentioned above, we create two threads t1 and t2. The thread (t1) writes the data. Use the PipedOutputStream object and the thread (t2) reads the data from that pipe. Both the piped stream objects are connected with each other.
 
Summary

Thus, we learnt that PipedInputStream and PipedOutputStream classes have a capability to read and write the data together in Java and also learnt how we can create it.