Frage zu Threads

[sisko78]

Also angenommen ich lasse mehrere Nebenthreads gleichzeitig laufen.
Ist es irgendwie möglich, aus dem Main Thread heraus zu bestimmen, wann welcher fertig ist und dann sofort darauf zu reagieren? Allerdings ohne im jeweiligen Threadobject eingreifen zu können (dort also kein Notify oder ähnliches).

Habe eben mal versucht, die Threads einem Vector hinzuzufügen und diesen immer wieder durchlaufen zu lassen, bis !isAlive() wahr wird (dann Thread aus Vector entfernen), aber das hat nicht so richtig funktioniert, und ist wahrscheinlich ne ziemlich dämliche Art und Weise.
Jemand einen Vorschlag?


Edit: mein Versuch, kann man das so machen? Scheint irgendwie zu funktionieren.

public void addResources(Object[] searchResources) {
    
   for (int i=0;i<searchResources.length;i++){

    ...
    
    //start Thread
    try {
      Thread t = (Thread)resourceObject; 
      threads.add(t); //Vector, dem Threads hinzugefügt werden
      t.start();      
    }
    catch (Exception ex) {ex.printStackTrace();}
  }
  traverseThreads(threads);
  }
  
  public void traverseThreads(Vector threads){
    
    for (int i=0;i<threads.size();i++){
      Thread t = (Thread)threads.elementAt(i);
     if (!t.isAlive()){
       this.threads.remove(t);
       addResourceKeywords(t);
     }
    
      try {
        Thread.currentThread().sleep(10);
      }
      catch (InterruptedException ex) {
      }
    
      traverseThreads(this.threads);
    }
  }

 

[Sky]

Wie wär's, wenn dein Thread ein Event feuert und Du mit einem Listener darauf reagierst!?

 

[sisko78]

Hm, das wäre wohl auch ne Möglichkeit.
Das Programm sollte eben möglichst mit weiteren Klassen erweiterbar sein, die ich mit dieser Methode hinzufügen kann, ich will es 3. so einfach wie möglich machen.
Die einzelnen Klassen, die hinzugefügt werden sollen, müssen momentan ein interface implementieren. Ich will Andern die Möglichkeit lassen, von Thread abzuleiten. Jetzt weiß ich nicht, wie ich das am besten mache.

Observable Klasse mit attach, detach und fireupdate
und dann dem Interface attach und detach methoden hinzufügen und entsprechende Hinweise (verwendung Observable Object per Delegation), dass bei der Implementierung am Ende der run() Methode fireupdate aufgerufen werden soll? Hm..
Oder wie macht man das am besten, so dass Andere dann keinen Stress mit den neu hinzuzufügenden Klassen bekommen.

Gruß
sisko78

 

[KISS]

waere es nicht einfacher an einer bestimmten stelle ein join ueber alle threads zu machen?

 

[sisko78]

eigentlich schon, aber es könnte durchaus passieren, das einige Threads erst nach mehreren Sekunden beendet sind (abfrage eines überlastetetn servers o.ä.) und da will ich eben nicht warten, bis alle Threads ein Ergebnis geliefert haben.

Gruß
sisko78

 

[sisko78]

Ein weiteres Problem, dass ich irgendwie nicht gelöst bekomme. Also angenommen, das mit den Threads funktioniert. Ich schaffe es einfach nicht die Tabelle (jede hinzugefügte Klasse liefert einen Vector, der eine Spalte in einer Tabelle darstellt) schon aktualisieren zu lassen, wenn einzelne Threads fertig sind. Die Tabelle wird immer erst angezeigt, wenn alle Einträge da sind. Dabei ist mein Tabellenmodell von AbstractTableModel abgeleitet und sollte die Anzeige doch aktualisieren, wenn sich am Modell was verändert?
Irgendwie hab ich das Ganze vom klassenaufbau her nicht so wirklich im Griff. Vielleicht weiß jemand, was ich meine, und kann mir, ohne seine Kristallkugel zu rate ziehen zu müssen, einen Tip geben.
Danke.

Gruß
sisko78