Konstante Zahl Threads parallel rechnen lassen

[Ede_123]

Hi,

ich bin mir sicher, dass ich nicht der Erste sein kann der dieses Problem hat, jedoch suche ich scheinbar nach den falschen Begriffen, oder gehe von vornherein ganz falsch an das Problem heran, denn bis jetzt habe ich noch nichts brauchbares gefunden.

Es geht um folgendes:
Ich habe eine Klasse (abgeleitet von Thread) die Berechnungen vornimmt. Diese Berechnungen sind voneinander unabhängig.

Ich möchte nun dass ständig mehrere dieser Threads ihre Arbeit verrichten (am besten soviele wie es Rechenkerne gibt), d.h. z.B. 4 Threads gestartet werden und erst wenn einer davon fertig ist, der nächste gestartet wird. Wie implementiere ich das sinnvoll?

Unten der Code, den ich bisher habe (der, der in der Main-Methode aufgerufen wird), dieser produziert allerdings (ist ja logisch) selbst schon eine sehr hohe CPU-Auslastung (sorry, irgendwie kann ich keinerlei formatierungen vornehmen, werde versuchen das bei Gelegenheit nachzuholen):

for(int x=0; x<irgendwas; x++) { //läuft durch alle "x" die berechnet werden müssen
	while(Thread.activeCount()>=4) {}; 	//<- führt selbstverständlich zu hoher CPU-Last
										//ein sleep() an dieser Stelle scheint die komplette Berechnung auszubremsen
	CalculationThread thread = new CalculationThread(x);
	thread.start();
}

 

[MiDniGG]

Also formatieren kannst Du mit [ JAVA] [/code] diese Java-Tasse da ^^

Wenn ich Deine Frage richtig verstanden habe würde ich es so machen:

for(int x = 0; x < grenze;) { //diese klammer ist bei Dir nicht...
     if(Thread.activeCount() < 5) {
          CalculationThread thread = new CalculationThread(x);
          thread.start();
          x++;
     }
}

Somit wird nur ein neuer Thread gestartet, wenn nicht schon 4 laufen... Damit die Schleife nicht schon zu früh aus is wird x auch nur erhöht, wenn ein Thread gestartet wird... Weiß nicht ob das Ideal ist. Aber es sollte Deinem Problem entgegenwirken

 

[Landei]

Warum wollen bloß alle ihren Krams immer wieder handschnitzen?

Mach aus deinen Threads Runnables und benutze einen ThreadPoolExecutor.

 

[newcron]

Auch wenn es prinzipiell immer gut ist, vorhandenes zu verwenden (ThreadPoolExecutor) hier dennoch eine Antwort auf die Frage:
Du würdest in deiner while (Thread.activeCount()>=4) {}; den Verwaltungsthread einfach mittels Thread.sleep(100) schlafen legen. Dann wird der vom VM Scheduler für 100ms Sekunden nicht mehr aufgerufen. In diesen 100ms Verbrät diese While schleife, die du in irgend einer Form benötigen würdest, keine CPU zeit.

Übrigens habe ich mal gehört, dass die Sun JVMs höchstens zwei Prozessoren verwalten können. Ob das noch immer/überhaupt stimmt, weiß ich nicht. Wie viele Prozessoren tatsächlich verfügbar sind, erfährst du mit Runtime.getRuntime().availableProcessors()

 

[Ede_123]

@MiDniGG: Danke, da hab ich nen Fehler eingebaut - Die Java-Tasse war nicht da, weil ich irgendwie in der Forensoftware ein eingeschränktes Interface eingestellt hatte
Zum Problem: Das was du beschreibst senkt die CPU-Last doch auch nicht? Nur statt in der while-Schleife, hängt er dann halt in der for-Schleife?

@Landei: Auf ThreadPoolExecutor bin ich während meiner Recherche schon mal gestoßen, ist mir in dem Moment allerdings für mein Problem zu aufwändig/unpassend erschienen, werde es mir jedoch noch mal anschauen.

@newcron: Ein sleep() einzubauen hatte ich ebenfalls versucht, allerdings sinkt die CPU-Last auf meinem System dann auf ~20% und die Berechnung dauert ewig - irgendwas bremst in diesem Fall gewaltig aus (hatte für sleep werte von (100,10,1)ms sowie (100,10,1)ns probiert, daran kanns wohl nicht liegen).

Soweit vielen Dank schon mal, falls ihr noch andere Ideen habt, nur her damit!

 

[faetzminator]

versuchs statt sleep() mit yield() Thread (Java 2 Platform SE 5.0)

 

[Ede_123]

Super faetzminator!
yield() scheint die Lösung zu sein, ich muss zwar nochmal genau testen, aber es scheint die CPU-Last des Main-Threads angenehm niedrig zu halten.

Ich denke das war die einfachste und zugleich wirkungvollste Lösung für mein Problem!