core-utils/com.pambrose.common.concurrent/Atomic

Atomic

class Atomic<T>(initValue: T)

A coroutine-safe wrapper around a mutable value, protected by a Mutex.

Provides suspending functions for reading and writing the value with mutual exclusion, as well as a non-locking value property for quick reads (volatile visibility only).

Parameters

initValue

the initial value

Type Parameters

the type of the wrapped value

Constructors

Atomic

constructor(initValue: T)

Properties

value

val value: T

The current value. Reads are volatile but not mutex-protected.

Functions

setWithLock

inline suspend fun setWithLock(owner: Any? = null, action: (T) -> T): T

Atomically updates the value by applying action to the current value while holding the Mutex.

withLock

inline suspend fun <V> withLock(owner: Any? = null, action: T.() -> V): V

Executes action on the current value while holding the Mutex and returns the result.

Atomic

Parameters

Type Parameters

See also

Constructors

Properties

Functions