agents-utils/ai.koog.agents.lock

Package-level declarations

Types

KeyedMutex

class KeyedMutex<K>

A keyed, suspend-friendly mutex for Kotlin Multiplatform.

RWLock

class RWLock

A Kotlin Multiplatform read-write lock that allows concurrent read access while guaranteeing exclusive write access.

Functions

withLock

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

Convenience function mirroring Mutex.withLock

withLockCheck

suspend fun Mutex.withLockCheck(check: () -> Boolean, message: () -> String, action: suspend () -> Unit)

Executes the given action within a lock provided by the Mutex. Before acquiring the lock, it checks a condition specified by check. If the condition is satisfied, the lock is not acquired, and the operation returns early after logging a message provided by message. If the condition is not satisfied, the lock is acquired, the condition is rechecked, and if still not satisfied, the action is executed.