2 Threads mit Pipe verbinden

[javadewd]

Also ich habe folgendes Problem.

Ich wollte die Kommunikation von 2 Threads mit Pipes ausprobieren, allerdings funktioniert die Ausgabe nicht ganz, scheinbar läuft das Programm in einer Endlosschleife.

folgender Code:
ThreadWriter.java

public class ThreadWriter extends Thread {

    private PipedWriter out;

    public ThreadWriter() {
        out = new PipedWriter();
        this.start();
    }

    public PipedWriter getWriter() {
        return out;
    }

    @Override public void run() {
        char x = 'a';
        try {
            for ( int i = 0; i < 10; i++ ) {
                out.write(x++);
            }
        } catch ( IOException ex ) {
            ex.getMessage();
        }
    }

} /* eof */

Thread der den Strom ausgeben soll
ThreadReader.java

public class ThreadReader extends Thread {

    private PipedReader in;

    public ThreadReader(PipedWriter out) throws IOException {
        in = new PipedReader( out );
        this.start();
    }

    @Override public void run() {
        int j = 0;
        try {
            while ( (j = in.read()) >= 0 ) { /* alternativ != -1 .. hab' nur getestet */
                System.out.println( (char)j );
                System.out.println ( "true" );
            }
        } catch ( IOException ex ) {
            ex.getMessage();
        }
    }

} /* eof */

TestClass.java

public class ThreadTest {
    public static void main(String[] args) {
        try {
            ThreadWriter tw = new ThreadWriter();
            ThreadReader tr = new ThreadReader( tw.getWriter() );
        } catch ( Exception ex ) {
            ex.getMessage();
        }
    }
    
}

Wie ihr seht ist es ein sehr einfach gehaltenes Programm. "Write end dead" IOException übersehe ich hier mal!
Wo liegt denn jetzt speziell der Fehler, weshalb die Ausgabe nicht ausgeführt wird?

vielen Dank für eure Hilfe!

 

[Gast2]

Hast du schon out.flush() nach dem write ausprobiert?

 

[javadewd]

alles ausprobiert : ).

 

[Gast2]

Hab mal die Startreihenfolge der beiden Threads geändert.
jeweils das this.start() aus dem Kontruktor raus und:

public class ThreadTest {
    public static void main(String[] args) {
        try {
            ThreadWriter tw = new ThreadWriter();
            ThreadReader tr = new ThreadReader( tw.getWriter() );
            tr.start();
            tw.start();
        } catch ( Exception ex ) {
            ex.getMessage();
        }
    }
}

Dann läufts
Vielleicht fliegt der output dann irgendwo ins nirvana wenn der reader noch nicht läuft :rtfm:

 

[javadewd]

Danke!

Weißt du, warum dieses Problem besteht, wenn sich die Threads selbst starten?