Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-V4) ~ foundjava

Click here to watch in Youtube :


Click the below Image to Enlarge

PipedReadWriteDemo.java

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class PipedReadWriteDemo
{

    public static void main(String[] args) throws IOException
    {
        PipedInputStream pis = new PipedInputStream();
        PipedOutputStream pos = new PipedOutputStream();
        pos.connect(pis);

        Runnable producer = () -> produceData(pos);
        Runnable consumer = () -> consumeData(pis);
        new Thread(producer).start();
        new Thread(consumer).start();
    }

    public static void produceData(PipedOutputStream pos)
    {
        try
        {
            for (int i = 1; i <= 5; i++)
            {
                pos.write((byte) i);
                pos.flush();
                System.out.println("Writing: " + i);
                Thread.sleep(500);
            }
            pos.close();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }

    public static void consumeData(PipedInputStream pis)
    {
        try
        {
            int num = -1;
            while ((num = pis.read()) != -1)
            {
                System.out.println("Reading: " + num);
            }
            pis.close();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }

    }
}

Output

Writing: 1
Reading: 1
Writing: 2
Reading: 2
Writing: 3
Reading: 3
Reading: 4
Writing: 4
Reading: 5
Writing: 5

Click the below link to download the code:

CLICK HERE