Future Variable

[Osix2000]

Also, Leute, die Sache mit den Future Variablen ist mir immer noch nicht ganz klar....
Das ist ja hammermässig kompliziert....

ExecutorService tp = Executors.newCachedThreadPool();

.
.                

Future <String>x = tp.submit(task[i]);                                                                
                        
.
.

Ich definiere als den ThreadPool tp und lege dann über eine Schleife die ich nicht beschrieben habe, eine Anzahl von tasks auf eine Future-Variable....

Wenn ich das richtig verstanden habe, dann wird das Future erst konkret wenn ich z.B. eine Get-Methode aufrufe

x.get ---> dann erst läut der draufgelegte und mit submit übergebene Task ab.....Oder ?


So und jetzt kommt meine Frage:

Damit ich alle Tasks von 0 bis i verwalten kann, brauche ich jetzt ja ein Future Array oder eine Future ArrayList ????

also sprich analog dazu ein x......

wie mache ich das ? Wie lautet die Deklaration

Future<ArrayList> klappt net.....

 

[jPat]

Probier mal das:
ArrayList <Future>

 

[byte]

Wenn ich das richtig verstanden habe, dann wird das Future erst konkret wenn ich z.B. eine Get-Methode aufrufe

x.get ---> dann erst läut der draufgelegte und mit submit übergebene Task ab.....Oder ?

Nein. Future.get() bewirkt lediglich, dass aus dem asynchronen Aufruf des Tasks quasi ein synchroner wird. Das heisst, der Kontrollfluss stopt, bis der Task abgelaufen ist.

Also:

1. Future f = executor.submit(task) => Der Task läuft parallel (asynchron).
2. du tust irgendwas parallel zum Task
3. f.get() => Hier stopt der Kontrollfluss, bis der Task beendet wird (synchron).

Ausserdem kriegt man bei Callables über das Future-Objekt den Rückgabewert des Tasks. Und (wie Du schon bemerkt hast) kann man über Future auch einen Task canceln.

 

[jPat]

Eventuell hilft dir das Hier weiter.

Also wie ich das Verstehe wartet get bis ein Ergebnis zurückkommt, aber die Berechnung startet vorher.

Future <String>x = tp.submit(task[i]);

Hier wird dein task schon ausgeführt laut api.

 

[osix2000]

zum vorhergehenden, oder ?

Die Task laufen alle parallel, aber asynchron....

Also wurde der Task auch gestartet...

Erst per x.get erhält er sozusagen, die volle Priorität. Keine Parallelrechnung mehr, nur noch dieser Task wird berechnet, bis das Ergebnis feststeht und das wird dann zurückgegeben...

Sehe ich das richtig, daß nachdem der Task beendet wurde, alle anderen Task wieder asynchron weiterrechnen, bis wieder per y.get ein anderer Task "angefordert" wird. ?

und WICHTIG:

Mit ist noch nicht klar, wie ich jetzt einen Task STOPPEN kann.... Kann mir dazu nochmal BITTE jemand einen Tipp geben ?