Wie funktioniert ein Mutex in Koroutinen?

Ein Mutex (Mutual Exclusion) in Coroutines bietet einen Mechanismus der gegenseitigen Ausschließung zum Schutz gemeinsamer Ressourcen vor gleichzeitigem Zugriff durch mehrere Coroutines.

Funktionsprinzip:

1. Mutex-Erfassung: Die Coroutine, die auf die geschützte Ressource zugreifen möchte, ruft die Methode lock() auf.
2. Blockierung: Wenn der Mutex frei ist, erwirbt die Coroutine ihn ohne Blockierung und setzt die Ausführung fort. Wenn der Mutex von einer anderen Coroutine besetzt ist, wird die aufrufende Coroutine bis zur Freigabe des Mutex ausgesetzt.
3. Freigabe des Mutex: Nach Abschluss der Arbeit mit der geschützten Ressource ruft die Coroutine die Methode unlock() auf, um den Mutex freizugeben.

Wichtige Merkmale in Coroutines:

• lock() nicht blockierend (bei Erwerb eines freien Mutex): Im Gegensatz zu traditionellen Threads, bei denen lock() den gesamten Thread blockieren kann, erfolgt bei Coroutines die Erfassung des Mutex, wenn dieser frei ist, ohne Blockierung.
• Coroutine-Suspendierung (bei belegtem Mutex): Wenn der Mutex belegt ist, blockiert die aufrufende Coroutine den Thread nicht, sondern setzt sie aus bis zur Freigabe. Dies gibt den Thread frei, um andere Coroutines auszuführen.
• Erweiterungsfunktion withLock: Bequeme Methode, um den Mutex zu verwenden, die ihn automatisch erfasst und freigibt, auch wenn innerhalb des Blocks eine Ausnahme auftritt.

Beispiel für die Verwendung:

import kotlinx.coroutines.*
import kotlinx.coroutines.sync.Mutex

val mutex = Mutex()
var counter = 0

suspend fun incrementCounter() {
    mutex.withLock {
        // Kritischer Abschnitt - geschützte Ressource
        counter++
        delay(10) // Arbeitssimulation
        println("Counter: $counter")
    } // Mutex wird hier automatisch freigegeben
}

fun main() = runBlocking {
    repeat(100) {
        launch {
            incrementCounter()
        }
    }
    delay(1000)
}

In diesem Beispiel ist incrementCounter ein kritischer Abschnitt, der die gemeinsame Ressource counter ändert. Der Mutex stellt sicher, dass nur eine Coroutine gleichzeitig Zugriff auf diesen Abschnitt hat, um Race Conditions zu vermeiden. Die Verwendung von withLock vereinfacht die Mutex-Verwaltung.