Привет всем! Я использую Mutex для изменения стейта, вот так

private val mutex: Mutex = Mutex()

protected suspend fun setState(reducer: State.() -> State) {
mutex.withLock {
_state.value = state.value.reducer()
Log.d(
"SET_STATE", "${reducer.javaClass.name}\n" +
_state.value.toString()
)
}
}

Сейчас начали всплывать креши с такой вот ошибкой
kotlinx.coroutines.CompletionHandlerException: Exception in resume onCancellation handler for CancellableContinuation(DispatchedContinuation[AndroidUiDispatcher@20ca558, Continuation at androidx.compose.foundation.gestures.PressGestureScopeImpl.reset(TapGestureDetector.kt:357)@f59af17]){Completed}@f52bf04
...
Caused by: java.lang.IllegalStateException: Mutex is not locked

Что может быть?

а какую задачу вы преследуете мьютексом на ui слое?

Иногда падала ошибка при изменении стейта одновременно

а вы меняете стейт на разных потоках?

А у вас Flow или LiveData?

abstract class BaseViewModel<State, Event, Effect>(initialState: State) : ViewModel() { private val _state = mutableStateOf(initialState) val state: androidx.compose.runtime.State<State> get() = _state private val _effect: Channel<Effect> = Channel() val effect = _effect.receiveAsFlow() private val _event = MutableSharedFlow<Event>() init { viewModelScope.launch { _event.collect(::handleEvents) } } private val mutex: Mutex = Mutex() protected suspend fun setState(reducer: State.() -> State) { mutex.withLock { _state.value = state.value.reducer() Log.d( "SET_STATE", "${reducer.javaClass.name}\n" + _state.value.toString() ) } } fun setEvent(event: Event) { viewModelScope.launch { _event.emit(event) } } abstract fun handleEvents(event: Event) protected fun setEffect(builder: () -> Effect) { viewModelScope.launch { _effect.send(builder()) } } } Это базовая.

Может быть StateFlow использовать для state? Он из коробки потокобезопасный