Click here to watch in Youtube :
https://www.youtube.com/watch?v=euQvR81fXgY&list=UUhwKlOVR041tngjerWxVccw
Click the below Image to Enlarge
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction) |
import java.io.IOException; import java.io.PipedInputStream; import java.io.PipedOutputStream; /* * Here, we have created two threads thread1 and * thread2. The thread1 thread writes the data using the * PipedOutputStream object and the thread2 thread reads * the data from that pipe using the PipedInputStream * object. Both the piped stream object are connected * with each other. */ public class PipedReadWriteDemo { public static void main(String[] args) throws IOException { final PipedOutputStream pout = new PipedOutputStream(); final PipedInputStream pin = new PipedInputStream(); /* * Connects this piped output stream to a receiver. * If this piped output stream object is already * connected to some other piped input stream, an * IOException is thrown. */ pout.connect(pin); /* * Creating one thread1 which writes the data */ Thread thread1 = new Thread() { public void run() { try { for (int i = 50; i <= 60; i++) { pout.write(i); System.out.println("PipedOutputStream Writing i =" + i); Thread.sleep(1000); } pout.close(); } catch (Exception exe) { exe.printStackTrace(); } } }; /* * Creating another thread2 which reads the data. */ Thread thread2 = new Thread() { public void run() { try { int i; while ((i = pin.read()) != -1) { System.out.println("PipedInputStream Reading i = " + i); } pin.close(); } catch (Exception exe) { exe.printStackTrace(); } } }; // starting both threads thread1.start(); thread2.start(); } }
PipedOutputStream Writing i =50 PipedInputStream Reading i = 50 PipedOutputStream Writing i =51 PipedInputStream Reading i = 51 PipedOutputStream Writing i =52 PipedInputStream Reading i = 52 PipedOutputStream Writing i =53 PipedInputStream Reading i = 53 PipedOutputStream Writing i =54 PipedInputStream Reading i = 54 PipedOutputStream Writing i =55 PipedInputStream Reading i = 55 PipedOutputStream Writing i =56 PipedInputStream Reading i = 56 PipedOutputStream Writing i =57 PipedInputStream Reading i = 57 PipedOutputStream Writing i =58 PipedInputStream Reading i = 58 PipedOutputStream Writing i =59 PipedInputStream Reading i = 59 PipedOutputStream Writing i =60 PipedInputStream Reading i = 60
Refer:
https://sites.google.com/site/ramj2eev1/home/javabasics/JavaIODemo_Piped_Intro_App.zip?attredirects=0&d=1
Github Link:
https://github.com/ramram43210/Java/tree/master/BasicJava/JavaIODemo_Piped_Intro_App
Bitbucket Link:
https://bitbucket.org/ramram43210/java/src/301d989d72a8b053f20342cfe0bd4a5c143c23aa/BasicJava/JavaIODemo_Piped_Intro_App/?at=master
See also:
No comments:
Post a Comment