[JAVA] aspettare che più thread finiscano

[lemming]

Come si fa a aspettare che una serie imprecisata di thread siano terminati.
Per aspettare che un thread th sia finito, faccio un thread (joinThread) e in run gli metto th.join
Se i thread sono più di uno e sono stati istanzati così:

Thread th[];

for(int i=0; i<100; i++)
{th[i] =new Thread();
th[i].start();}

Thread joinThread = new Thread();
???

Il problema è perchè quando istanzo il joinThread non è detto che tutti i Thread th siano stati finiti. Però dovrebbero essere stati istanziati tutti.
Quindi avrei pensato di fare qualcosa tipo

il run di joinThread -->

run(){
for(int q =0; q >=th.length; q++)
{ try {th[q].join(); }
catch...}
altraFunzione();
}
altraFunzione dovrebbe essere eseguita quando tutti i th sono finiti.
Dov' è il problema?
altraFunzione mi viene eseguita prima che tutti i thread concludano la loro vita.

[mad_hhatter]

Originariamente inviato da lemming

Come si fa a aspettare che una serie imprecisata di thread siano terminati.
Per aspettare che un thread th sia finito, faccio un thread (joinThread) e in run gli metto th.join
Se i thread sono più di uno e sono stati istanzati così:

Thread th[];

for(int i=0; i<100; i++)
{th[i] =new Thread();
th[i].start();}

Thread joinThread = new Thread();
???

Il problema è perchè quando istanzo il joinThread non è detto che tutti i Thread th siano stati finiti. Però dovrebbero essere stati istanziati tutti.
Quindi avrei pensato di fare qualcosa tipo

il run di joinThread -->

run(){
for(int q =0; q >=th.length; q++)
{ try {th[q].join(); }
catch...}
altraFunzione();
}
altraFunzione dovrebbe essere eseguita quando tutti i th sono finiti.
Dov' è il problema?
altraFunzione mi viene eseguita prima che tutti i thread concludano la loro vita.

quel for ha qualcosa che non mi torna

[lemming]

Cosa th.length ? Ho sbagliato a copiare nel post, scusa, era q>th.length

[mad_hhatter]

Originariamente inviato da lemming

Cosa th.length ? Ho sbagliato a copiare nel post, scusa, era q>th.length

peggio ancora il blocco del for non lo esegui neanche una volta e così passi subito oltre. devi mettere < non >

[^TiGeRShArK^]

cmq per il problema principale mi sa che basta una barriera.
http://java.sun.com/j2se/1.5.0/docs/...icBarrier.html

[lemming]

Interessante la cosa della CyclicBarrier, ma come funziona, non ho capito molto?

Per mad_hhater: Ecco cosa succede a riutilizzare il codice (copia-incolla)

[^TiGeRShArK^]

L'esempio che c'è in cima al javadoc mi pare piuttosto auto-esplicativo
cmq il punto importante è la chiamata a barrier.await() che mette il singolo thread in attesa che gli altri finiscano.

[lemming]

Grazie