Threads, Synchronisation

Viele aktuelle Prozessoren haben mehr als einen Kern und sind so in der Lage, mehrere Programme gleichzeitig auszuführen. Die Programmiersprache Java ermöglicht es, dies auszunutzen und mehrere Methoden zu starten, die dann gleichzeitig ausgeführt werden. Mann spricht dann von mehreren Threads („Ausführungssträngen“).

Genauer:

Falls genug Prozessorkerne zur Verfügung stehen, werden die Threads echt parallel ausgeführt.
Falls nicht genug Prozessorkerne zur Verfügung stehen, werden die Threads abwechselnd pausiert/fortgeführt (preemptive Multitasking).

Um einen Thread parallel zum Hauptprogramm zu starten schreibt man eine Klasse (z.B. MyTask), die das Interface Runnable implementiert und schreibt die Anweisungen, die ausgeführt werden sollen, in ihre run-Methode:

class MyTask implements Runnable {
   void run(){
      // Die Anweisungen, die hier stehen, werden parallel zum Hauptprogramm ausgeführt.
   }
}

Anschließend übergibt man ein MyTask Objekt an ein Thread-Objekt und ruft dessen start-Methode auf:

Thread t = new Thread(new MyTask());
t.start();
 
// Alle Anweisungen ab hier werden schon parallel zur run-Methode des MyTask-Objekts ausgeführt!

Die start-Methode führt dann die run-Methode in einem neuen Thread parallel zum Hauptprogramm aus.

Beispiel 1: 11 Threads zählen gleichzeitig

Race condition und Lösungen

Im folgenden Beispiel gibt es nur ein einziges Objekt der Klasse Counter. Drei Threads, die gleichzeitig laufen, erhöhen je 1 Million-mal diesen Counter.
Am Ende der Arbeit meldet jeder Thread den aktuellen Zustand des Counters. Man würde erwarten, dass der Thread, der als letztes fertig wird, die Zahl 3000000 ausgibt.

Starten Sie das Programm mehrmals und sehen Sie sich die Ausgabe an.
Wie lässt sich die Ausgabe erklären?

Im rechts stehenden Sequenzdiagramm ist zu sehen, was passiert, wenn zwei Threads gleichzeitig die Methode increment() des Counter-Objekts aufrufen. Stellen Sie sich vor, das Attribut counter hat zu Beginn den Wert 4. Der blaue Thread ist etwas früher dran als der grüne, trotzdem erfolgt die Anweisung counter = i des blauen Threads erst nach der Anweisung i = counter des grünen Threads. Das hat zur Folge, dass sowohl die grüne Variable i als auch die blaue jeweils auf 5 erhöht werden. Am Ende wird zweimal derselbe Wert 5 in die Variable counter geschrieben, so dass sie folglich nur um eins erhöht wurde, obwohl die Methode increment() zweimal aufgerufen wurde.

Man nennt diesen Effekt eine race condition. Sie entsteht dadurch, dass die Anweisungen in der Methode increment() von mehr als einem Thread gleichzeitig ausgeführt werden. Man spricht von einem kritischen Abschnitt.

Synchronized-Methode

Setzt man vor die Deklaration der Methode increment das Schlüsselwort synchronized, so sorgt der Compiler dafür, dass zur Laufzeit jeweils nur ein Thread die Methode „betreten“ darf. Nachfolgende Threads werden blockiert (d.h. in der Ausführung angehalten) bis der erste Thread die Methode wieder verlassen hat. Erst dann wird einer der blockierten Threads wieder fortgesetzt.

Vergleichen Sie die Deklaration der Methode increment im folgenden Programm mit der Deklaration im vorangegangenen Programm.
Starten Sie das Programm mehrmals. Erklären Sie die Ausgabe!