Write end dead exception using PipedInputStream java

by

“Write end dead” exceptions will arise when you have:

  • A PipedInputStream connected to a PipedOutputStream and
  • The ends of these pipe are read/written by two different threads
  • The threads finish without closing their side of the pipe.

To resolve this exception, simply close your Piped Stream in your Thread’s runnable after you have completed writing and reading bytes to/from the pipe stream.

Here is some sample code:

final PipedOutputStream output = new PipedOutputStream();
final PipedInputStream input = new PipedInputStream(output);

    Thread thread1 = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                output.write("Hello Piped Streams!! Used for Inter Thread Communication".getBytes());                       
                output.close();

            } catch(IOException io) {
                io.printStackTrace();
            }                   
        }
    });

    Thread thread2 = new Thread(new Runnable() {
        @Override
        public void run() {

            try {

                int data;

                while((data = input.read()) != -1) {
                    System.out.println(data + " ===> " + (char)data);
                }

                input.close();

            } catch(IOException io) {
                io.printStackTrace();
            } 

        }
    });

    thread1.start();
    thread2.start();

Complete code is here: https://github.com/prabhash1785/Java/blob/master/JavaCodeSnippets/src/com/prabhash/java/io/PipedStreams.java

For more details, please have a look at this nice blog: https://techtavern.wordpress.com/2008/07/16/whats-this-ioexception-write-end-dead/

More Related Contents:

  1. How do servlets work? Instantiation, sessions, shared variables and multithreading
  2. What operations in Java are considered atomic?
  3. When exactly do you use the volatile keyword in Java? [duplicate]
  4. Thread safe multitons in Java
  5. Error message “unreported exception java.io.IOException; must be caught or declared to be thrown” [duplicate]
  6. Is a volatile int in Java thread-safe?
  7. Java Singleton and Synchronization
  8. Java Executors: how can I set task priority?
  9. Java ProcessBuilder: Resultant Process Hangs
  10. inter thread communication in java
  11. Volatile variable in Java
  12. When does the main thread stop in Java?
  13. What is the JVM thread scheduling algorithm?
  14. How does `this` reference to an outer class escape through publishing inner class instance?
  15. Why we call Thread.start() method which in turns calls run method?
  16. Does close ever throw an IOException?
  17. How do I prove programmatically that StringBuilder is not threadsafe?
  18. When does a Java Thread reach the ‘Die’ State
  19. How does the event dispatch thread work?
  20. Which concurrent Queue implementation should I use in Java?
  21. How to abort a thread in a fast and clean way in java?
  22. AsyncTask.executeOnExecutor() before API Level 11
  23. Why is there no GIL in the Java Virtual Machine? Why does Python need one so bad?
  24. How does the JVM terminate daemon threads? or How to write daemon threads that terminate gracefully
  25. Static method behavior in multi-threaded environment in java
  26. How does Keep-alive work with ThreadPoolExecutor?
  27. Setting Ideal size of Thread Pool [duplicate]
  28. Dynamically refresh JTextArea as processing occurs?
  29. What makes the execution order of threads unpredictable?
  30. Updating your UI and forcibly waiting before continuing JavaFX

Leave a Comment