From d237a18aae9850e3515a8a68485a44bcbf7747d5 Mon Sep 17 00:00:00 2001 From: Dude so hot Date: Sat, 19 Oct 2024 21:26:53 +0800 Subject: [PATCH] Refine Naming --- app/src/main/kotlin/moe/tarsin/coroutines/NamedMutex.kt | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/app/src/main/kotlin/moe/tarsin/coroutines/NamedMutex.kt b/app/src/main/kotlin/moe/tarsin/coroutines/NamedMutex.kt index 10276acc6..7537e7025 100644 --- a/app/src/main/kotlin/moe/tarsin/coroutines/NamedMutex.kt +++ b/app/src/main/kotlin/moe/tarsin/coroutines/NamedMutex.kt @@ -13,7 +13,7 @@ class MutexTracker(mutex: Mutex = Mutex(), private var count: Int = 0) : Mutex b get() = count == 0 } -val mutexPool = object : DefaultPool(capacity = 32) { +object MutexPool : DefaultPool(capacity = 32) { override fun produceInstance() = MutexTracker() override fun validateInstance(mutex: MutexTracker) { check(!mutex.isLocked) @@ -25,7 +25,7 @@ val mutexPool = object : DefaultPool(capacity = 32) { value class NamedMutex(val active: MutableScatterMap = mutableScatterMapOf()) suspend inline fun NamedMutex.withLock(key: K, owner: Any? = null, action: () -> R): R { - val mutex = synchronized(active) { active.getOrPut(key) { mutexPool.borrow() }.inc() } + val mutex = synchronized(active) { active.getOrPut(key) { MutexPool.borrow() }.inc() } return try { mutex.withLock(owner, action) } finally { @@ -33,7 +33,7 @@ suspend inline fun NamedMutex.withLock(key: K, owner: Any? = null, act mutex.dec() if (mutex.isFree) { active.remove(key) - mutexPool.recycle(mutex) + MutexPool.recycle(mutex) } } }