Monday 19 September 2016

Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-V3)


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

Click the below Image to Enlarge
Java Tutorial : Java IO (PipedInputStream and PipedOutputStream-V3) 
PipedReadWriteDemo.java
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


public class PipedReadWriteDemo
{

    final static PipedOutputStream pipedOut = new PipedOutputStream();
    final static PipedInputStream pipedIn = new PipedInputStream();

    class PipedOutputThread implements Runnable
    {
        @Override
        public void run()
        {
            for (int i = 1; i <= 5; i++)
            {
                try
                {
                    pipedOut.write(("Hello " + i + "\n").getBytes());
                    Thread.sleep(1000);
                }
                catch (IOException e)
                {
                    e.printStackTrace();
                }
                catch (InterruptedException e)
                {
                    e.printStackTrace();
                }
            }
        }
    }

    class PipedInputThread implements Runnable
    {
        @Override
        public void run()
        {
            try
            {
                int i = 0;
                while ((i = pipedIn.read()) != -1)
                {
                    System.out.print((char) i);
                }
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args)
    {
        try
        {
            pipedOut.connect(pipedIn);
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
        ExecutorService service = Executors.newFixedThreadPool(2);
        PipedReadWriteDemo pipedWriteReadDemo=new PipedReadWriteDemo();
        service.execute(pipedWriteReadDemo.new PipedOutputThread());
        service.execute(pipedWriteReadDemo.new PipedInputThread()); 
    }
}
Output
Hello 1
Hello 2
Hello 3
Hello 4
Hello 5

Click the below link to download the code:
https://sites.google.com/site/ramj2eev1/home/javabasics/JavaIODemo_Pipes_Runnable_App.zip?attredirects=0&d=1

Github Link:
https://github.com/ramram43210/Java/tree/master/BasicJava/JavaIODemo_Pipes_Runnable_App

Bitbucket Link:
https://bitbucket.org/ramram43210/java/src/301d989d72a8b053f20342cfe0bd4a5c143c23aa/BasicJava/JavaIODemo_Pipes_Runnable_App/?at=master

See also:
  • All JavaEE Viedos Playlist
  • All JavaEE Viedos
  • All JAVA EE Links
  • Servlets Tutorial
  • All Design Patterns Links
  • JDBC Tutorial
  • Java Collection Framework Tutorial
  • JAVA Tutorial
  • Kids Tutorial
  • No comments:

    Post a Comment