MsgSteam und ErrorStream von Threads auslesen

[Markus XXX]

Hallo Zusammen.

Ich habe mir ein kleines Programm (Quellcode auszugsweise anbei) geschrieben, welches einen Prozess startet und dessen Ausgabe ausliest.
In der Klasse StreamTaker (im Konstruktor) wird der Prozess erzeugt und gestartet.
Nach dem der Prozess gestartet wurde -

Process proc = rt.exec(cmd)

-
wird dann mittels

this.start()

die Runmethode der Klasse StreamTaker (die ja von
der Klasse Thread erbt) aufgerufen.
Zuerst soll eine mögliche Fehlermeldung aus dem ErrorStream gelsen werden und danach eine mögliche
MsgStream Meldung.
Wenn ich jetzt z.B. eine Batch Datei starte, die nur eine MsgNachricht enthält, dann bleibt das Programm an der Stelle tmp = br.readLine() hängen, ohne Exception, ohne tmp mit NULL zu belegen.
Wird jedoch eine ErrorMsg geschrieben, dann ist alles ok.

Das Programm hängt bei zwei Konstellationen:
Batch liefert Fehlermeldung --> Falls zuerst Zugriff auf MsgStream --> bleibt hängen
Batch liefert Msg --> Falls zuerst Zugriff auf ErrorStream --> bleibt hängen

Ändere ich jedoch den Quellcode so, daß ich bei einer Fehlermeldung zuerst auf den ErrorStream und dann auf den MsgStream zugreife, dann läuft es seltsamerweise normal durch ???:L

public class StreamTaker extends Thread
{
    private InputStream msgStream;
    private InputStream errorStream;
    private String errorText;
    private String msgText;

    public static void main (String [] args)
    {
        StreamTaker st = new StreamTaker(new File("./test.bat"));
        System.out.println(st.getErrorText());
        System.out.println(st.getMsgText());
    }

    public StreamTaker(File f)
    {
        try
        {
            String[] cmd = new String[3];

            cmd[0] = "cmd.exe";
            cmd[1] = "/C"; // Schließt die Konsole nach Beendigung
            cmd[2] = f.getAbsolutePath();

            Runtime rt = Runtime.getRuntime();
            Process proc = rt.exec(cmd);
            this.errorStream = proc.getErrorStream();
            this.msgStream = proc.getInputStream();
            
            this.start(); // Mittels Thread die Infos aus der Konsole auslesen

            this.errorValue = proc.waitFor();
            
        }
        catch (Throwable t)
        {
            t.printStackTrace();
        }
    }

    @Override
    public void run()
    {
        BufferedReader br = null;
        String tmp = null;

        try
        {
            br = new BufferedReader (new InputStreamReader(this.errorStream));

            while ((tmp = br.readLine()) != null)
                this.errorText = this.errorText + tmp + "\n";

            br.close();
            br = new BufferedReader(new InputStreamReader(this.msgStream));
            tmp = null;

            while ((tmp = br.readLine()) != null)
                this.msgText = this.msgText + tmp + "\n";

            br.close();
            System.out.println("**");
        }
        catch (IOException ioe)
        {
            ioe.printStackTrace();
        }
    }

 

[Michael...]

ich würde mal die beiden Schleifen zum Lesen aus den Streams in separate Threads packen. Denn die erste blockiert ja solange bis readLine() null zurück liefert

 

[Markus XXX]

ich würde mal die beiden Schleifen zum Lesen aus den Streams in separate Threads packen. Denn die erste blockiert ja solange bis readLine() null zurück liefert

Genau das ist aber der Haken: Es wird nie NULL zurückgeliefert, auch wenn ich

System.out.println(tmp = br.readLine())

ausgebe :autsch:

 

[Michael...]

Genau das ist aber der Haken: Es wird nie NULL zurückgeliefert, auch wenn ich

System.out.println(tmp = br.readLine())

ausgebe :autsch:

Genau, und deswegen blockiert die erste Schleife. readLine() wartet ja solange bis der Stream irgendwas liefert.
<edit>Und nur weil auf dem ErrorStream nichts übertragen wird, heisst das noch lange nicht, dass null geliefert wird.</edit>

null wird vermutlich erst zurückgeliefert, wenn der Prozess beendet ist. Daher beide Schleifen in einen jeweils separaten Thread, damit man "parallel" von beiden Streams lesen kann.

 

[Markus XXX]

Habs ausprobiert und du hast recht :applaus: :applaus: :applaus:
Danke für die schnelle Hilfe!