Ako pomáhajú Coroutine Actors vyhnúť sa súťažným podmienkam pri vykonávaní paralelných operácií?

Herci korutín sú vzorom v Kotlin Coroutines, ktorý pomáha spravovať stav a vykonávať paralelné operácie bez súťažných podmienok.

Ako to funguje:

• Herec je korutína, ktorá spracováva postupne prichádzajúce správy (príkazy).
• Všetky zmeny stavu sa dejú vnútri tejto korutíny, čo zaručuje sekvenčný prístup k údajom.
• Iné korutíny komunikujú s hercom odoslaním správ, bez priamej zmeny stavu.

Týmto spôsobom sa vyhýba súťažná podmienka, pretože nie je paralelný prístup ku zdieľanému stavu — všetky operácie sa vykonávajú po sebe vnútri herca.

Príklad:

sealed class CounterMsg
object IncCounter : CounterMsg()
class GetCounter(val response: CompletableDeferred<Int>) : CounterMsg()

fun CoroutineScope.counterActor() = actor<CounterMsg> {
    var counter = 0
    for (msg in channel) {
        when (msg) {
            is IncCounter -> counter++
            is GetCounter -> msg.response.complete(counter)
        }
    }
}

// Použitie
val counter = counterActor()
counter.send(IncCounter)
val response = CompletableDeferred<Int>()
counter.send(GetCounter(response))
println("Counter = ${response.await()}")

Tento prístup zjednodušuje písanie bezpečného paralelného kódu bez použitia zámkov a zložitých mechanizmov synchronizácie.