Thread recycling

[styggje]

Hallo liebes Forum,

ich moechte gerne mit einer vorab gegebenen Anzahl an Threads eine Aufgabe parallel ausfuehren.
Im Prinzip wird eine Berrechnung durchgefuehrt bei der jeder Thread einen Teil einer Gesamtsumme beitraegt.

Mein Ansatz ist der:
1. statisches Array mit fester Anzahl initialisierter Threads
2. (synchronized) Monitor auf den die Threads zugreifen und die ihren Teil zur Summe addieren.

Mein Problem ist, dass es mehr Aufgaben als Threads gibt. Daher soll ein Thread nachdem er fertig ist, wieder neu gestartet werden und eine weitere Aufgabe ausfuehren bis eben alle Aufgaben fertig sind.
Im folgenden Kode ist m= die Anzahl der Aufgaben, und decision = Anzahl der Threads.

for (int j = 1; j <= m; j++) {
			for (int i = 0; i < decision; i++) {
                               //---------???
				Thread[i].start();
                               //---------???
			}
		}

Koennt ihr mir einen Tipp geben wie ich das am elegantesten angehen soll?
Laesst sich das mit ThreadGroups oder Executor/ThreadPools irgendwie loesen?
Habe einiges mit State Abfragen versucht. Sowas wie:

if(Thread[i].getState() == Thread.State.NEW){ dann fuehre aus}
else if( Thread[i].getState()... usw

Allerdings kam ich damit nicht weit und habe ausserdem das Gefuehl dass das der Holzpfad ist.
Gruss
styggje

 

[Noctarius]

Du magst vermutlich einen Thread-Pool nutzen

Executor (Java 2 Platform SE 5.0)

 

[Atze]

jo, geht wohl nur mit dem pool, denn neustarten kannst du threads nicht, wenn er einmal aus dem running raus ist. außnahmen sind wait und request abort. zweitest macht der thread aber nur intern.

 

[styggje]

Absolut!
Danke euch fuer die Tipps!

Fuers Protokoll meine Loesung (mit code von oben)

ExecutorService executor = 
               Executors.newFixedThreadPool(decision);

for (int j = 1; j <= m; j++) {
            for (int i = 0; i < decision; i++) {
                //Anpassung des Threads zu Runnable...
                 Runnable r = new Thread(xy); 

                executor.execute(r);
            }
        }

 

[tfa]

Das [c]new Thread[/c] kannst du dir sparen. Dem Executor genügen Runnables.