Kaip Coroutine Actors padeda išvengti lenktynių sąlygų atliekant lygiagrečias operacijas?

Korutinos aktoriai yra pavyzdys Kotlin Coroutines, kuris padeda valdyti būseną ir vykdyti paralelines operacijas be lenktynių sąlygų.

Kaip tai veikia:

• Aktorius yra korutina, kuri nuosekliai apdoroja įeinančias žinutes (komandas).
• Visos būsenos pakeitimai vyksta šioje korutinoje, užtikrinant nuoseklų duomenų prieigą.
• Kitos korutinos sąveikauja su aktoriumi siunčiant žinutes, nekeičiant būsenos tiesiogiai.

Taip išvengiama lenktynių sąlygų, nes nėra paralelios prieigos prie bendros būsenos — visos operacijos vykdomos eilės tvarka aktoriaus viduje.

Pavyzdys:

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)
        }
    }
}

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

Šis požiūris supaprastina saugaus paralelinio kodo rašymą be užraktų ir sudėtingų sinchronizacijos mechanizmų naudojimo.