JAVA EE: Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-Introduction)

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)

PipedReadWriteDemo.java

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();
    }
}

Output

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://docs.oracle.com/javase/8/docs/api/index.html?java/io/PipedInputStream.html



https://docs.oracle.com/javase/8/docs/api/index.html?java/io/PipedOutputStream.html