threads

[Ela]

hi leute.
ich bin gerade dabei ein kleines programm zu schreiben. es geht darum, dass ich mich dadurch auf mehreren ftp-servern gleichzeitig verbinden können soll. hab's nun versucht durch threads zu realisieren, was auch soweit klappt. mein problem ist aber, wie kann ich von aufrufender klasse aus irgendwie prüfen ob in den einzelnen threads die aufgabe erledigt bzw. nicht erledigt wurde. d.h. ich bräuchte eigentlich einen rückgabewert, so dass das "hauptprogamm" (bitte nicht steinigen ) sozusagen erst dann schließt bzw. ne ausgabe macht, wenn es alle ergebnisse der einzelnen threads "zusammen hat".
oh mann , das ist ganz schwer zu beschreiben
in einem satz: das objekt von dem aus ich z.b. 5 threads starte (die sich jeweils auf nen anderen server einloggen) soll erst dann beendet werden, wenn der letzte thread ne rückmeldung gibt (ob timeout oder eingeloggt) ABER es muss auch auslesen können ob erfolgreich oder nicht ....

ich hänge hier schon seit gestern dran und find einfach keine lösung ...

vielleicht gibts da nen ganz anderen ansatz für so einen multi-thread-client?

ich hoffe ihr könnt mir helfen und bedanke mich schon mal im voraus. ich selbst bin mit meinem latein am ende

mfg,
ela.

 

[Beni]

Mach zwei Variablen "boolean finished" und "boolean logged". Der erste wird auf true gesetzt, sobald der Thread fertig ist, der zweite gibt an, ob man drin ist (oder halt nicht).

Mit Object.wait( long time ) und Object.notify könntest du das Hauptprogramm zum warten bringen.

 

[Ela]

ja aber wenn der letzte thread mit System.exit() abgeschlossen wird, dann ist das Programm zu Ende. D.h. Hauptprogramm wird dann ja sowieso eher fertig als die 5 Threads. Und sobald der letzte der 5 durch ist, ist's vorbei. Also kommt ich net dazu da noch nachzuschauen ob eben dieser erfolgreich war oder nicht. Oder sehe ich das falsch?
Übrigens wenn ich so einen Thread nach sagen wir mal 5 Sek mit stop() anhalte, dann "hängt" mein Programm. Gibts da andere alternativen? Ich glaub nämlich das liegt wohl an dem System.exit() dass alles geschlossen wird.

Und dankeschön für die Hilfe

MfG,
Ela.

 

[Beni]

Schau mal, was man mit wait, notify und synchronized alles machen kann:

public class ThreadTest {
  public static void main( String[] args ){
    TestThread a = new TestThread( 1 );
    TestThread b = new TestThread( 2 );
    TestThread c = new TestThread( 3 );
    
    // Threads starten
    a.start();
    b.start();
    c.start();
    
    // Erst wenn alle Threads fertig sind, werden diese 3 Aufrufe beendet sein.
    a.block();
    b.block();
    c.block();
    
    // Überprüfen, ob wirklich alle Threads fertig sind
    System.out.println( "a.finished = " + a.isFinished() );
    System.out.println( "b.finished = " + b.isFinished() );
    System.out.println( "c.finished = " + c.isFinished() );
    
    // Und fertig
    System.out.println( "Alle Threads abgeschlossen" );
  }
}

class TestThread extends Thread{
  private boolean finished = false;
  private Object lock = new Object();
  private int index;
  
  public TestThread( int index ){
    this.index = index;
  }
  
  public void run(){
    for( int i = 0; i < 5 && !isInterrupted(); i++ ){
      System.out.println("run " + index);
      try {
        Thread.sleep( (long) (Math.random() * 2000));
      }
      catch (InterruptedException ex) {
      }
    }
    
    synchronized( lock ){
      finished = true;
      System.out.println( "lock " + index );
      lock.notifyAll();
    }
  }
  
  public boolean isFinished(){
    return finished;
  }
  
  public void block(){
    synchronized( lock ){
      if( !finished ){
        try {
          System.out.println( "wait " + index );
          lock.wait();
        }
        catch (InterruptedException ex) {
        }
      }
      else
        System.out.println( "jump " + index );
    }
  }
}

Das Programm wird erst beendet, wenn alle Threads fertig sind. Und das Programm bemerkt dies, kann noch eine Nachricht rausschicken.

Und stop solltest du vermeiden. Thread.interrupt() ist besser (dann musst du im inneren auf Thread.isInterrupted() überprüfen, und wenn dies true ist, abbrechen)

 

[Ela]

das ist super. vielen lieben dank für die (VOR ALLEM AUCH) schnelle hilfe. ich werde mir das mal ganz genau anschauen. das ist echt super nett von dir!!!

EDIT: Ich glaub genau das hab ich gebraucht. Ich weiß gar nicht was ich sagen soll als einfach nur daaankeeee

mfg,
ela.

 

[Ela]

eine frage hab ich noch und zwar, was das mit der ausgabe "jump" sein soll. ich verstehe da jetzt nicht ganz den sinn von ...

edit: ich glaub ich hab's kapiert. das tritt also dann ein, wenn der nicht warten muss, bis run() beendet ist -> ist schon beendet, wegen isFinisched ist true.

edit: so, funktioniert alles einwandfrei. vielen lieben dank nochmal!!!

mfg,
ela.