JAVA EE: Java Tutorial : Java IO (PipedReader and PipedWriter-Introduction)

Tuesday 20 September 2016

Java Tutorial : Java IO (PipedReader and PipedWriter-Introduction)

Click here to watch in Youtube :
https://www.youtube.com/watch?v=Gugjx1it5W8&list=UUhwKlOVR041tngjerWxVccw

Click the below Image to Enlarge

Java Tutorial : Java IO (PipedReader and PipedWriter-Introduction)

PipedReadWriteDemo.java

import java.io.IOException;
import java.io.PipedReader;
import java.io.PipedWriter;

/*
 * Here, we have created two threads thread1 and
 * thread2. The thread1 thread writes the data using the
 * PipedWriter object and the thread2 thread reads the
 * data from that pipe using the PipedReader object.
 * Both the pipedWriter and pipedreader objects are
 * connected with each other.
 */
public class PipedReadWriteDemo
{

    public static void main(String[] args) throws IOException
    {

        final PipedWriter pw = new PipedWriter();
        final PipedReader pr = new PipedReader();

        /*
         * Connects this piped writer to a receiver. *
         */
        pw.connect(pr);
        /*
         * Creating one thread1 which writes the data
         */
        Thread thread1 = new Thread()
        {
            public void run()
            {

                try
                {
                    pw.write("Hello World");
                    pw.write(",Welcome to india");
                    Thread.sleep(1000);
                }
                catch (Exception exe)
                {
                    exe.printStackTrace();
                }
                try
                {
                    pw.close();
                }
                catch (IOException e)
                {
                    e.printStackTrace();
                }

            }
        };
        /*
         * Creating another thread2 which reads the data.
         */
        Thread thread2 = new Thread()
        {
            public void run()
            {
                try
                {
                    int i;
                    while ((i = pr.read()) != -1)
                    {
                        System.out.print((char) i);
                    }
                }
                catch (Exception exe)
                {
                    exe.printStackTrace();
                }
                try
                {
                    pr.close();
                }
                catch (IOException e)
                {
                    e.printStackTrace();
                }
            }
        };
        // starting both threads
        thread1.start();
        thread2.start();
    }
}