Java/File Input Output/PipedWriter

PipedReader and PipedWriter and thread

   <source lang="java">

import java.io.IOException; import java.io.PipedReader; import java.io.PipedWriter; class MyThread extends Thread {

 private PipedReader pr;
 private PipedWriter pw;
 MyThread(String name, PipedReader pr, PipedWriter pw) {
   super(name);
   this.pr = pr;
   this.pw = pw;
 }
 public void run() {
   try {
     if (getName().equals("src")) {
       for (int i = 0; i < 15; i++)
         pw.write("src " + " A" + i + "\n"); 
       pw.close();
     } else {
       int item;
       while ((item = pr.read()) != -1)
         System.out.print((char) item); 
       pr.close();
     }
   } catch (IOException e) {
   }
 }

} class PipedThreads {

 public static void main(String[] args) throws Exception {
   PipedWriter pw = new PipedWriter();
   PipedReader pr = new PipedReader(pw);
   MyThread mt1 = new MyThread("src", pr, pw);
   MyThread mt2 = new MyThread("dst", pr, pw);
   mt1.start();
   Thread.sleep(2000);
   mt2.start();
 }

}

</source>