I’m trying to implement concurrent system using actor models. Not able to wrap my head around sending delayed message to actor. Attaching my snippet to implement the same. Is this correct?

Hi @Kshitij Patil why yould you need the delayActor? Sending msgs to the stateActor does not need to be serialized. Maybe a simple

launch

would do and make your life easier?

I showed state actor with default construct for simplicity. But I believe stateful actors need to be serialized and should not have access to launch async job as this might lead to concurrency issues. Have posted one proposal for stateful actor here https://github.com/Kotlin/kotlinx.coroutines/issues/87#issuecomment-1467456899

I was thinking about somthing along the line of:

fun delayedIncrement() {
    scope.launch { 
        delay(5.seconds)
        stateActor.sendChannel.send(StateIntent.Increment)
    }
}

Then you’re tying delayed jobs to parent scope. I was thinking if we should have separate scope for all the delayed messages. We can even make delayActor to

launch { }

new coroutine on every message.

scope

is supposed to be the scope that you also start the state actor on

One idea was this could be stateless actor launching multiple child actors (Async Coroutines) to process single mailbox. I thought it would be better if we encapsulate this into separate class so that it doesn’t interfere with other state variables in the

System