Coroutine Actors — это паттерн в Kotlin Coroutines, который помогает управлять состоянием и выполнять параллельные операции без состояния гонки.

Как это работает:

Actor — это корутина, которая последовательно обрабатывает входящие сообщения (команды).
Все изменения состояния происходят внутри этой корутины, что гарантирует последовательный доступ к данным.
Другие корутины взаимодействуют с Actor через отправку сообщений, не изменяя состояние напрямую.

Таким образом, состояние гонки исключается, потому что нет параллельного доступа к общему состоянию — все операции выполняются по очереди внутри Actor.

Пример:

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

// Использование
val counter = counterActor()
counter.send(IncCounter)
val response = CompletableDeferred<Int>()
counter.send(GetCounter(response))
println("Counter = ${response.await()}")

Такой подход упрощает написание безопасного параллельного кода без использования блокировок и сложных механизмов синхронизации.

Каким образом Coroutine Actors помогают избегать состояния гонки при выполнении параллельных операций?