| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ConflatedChannel.kt | 26 override val isEmpty: Boolean get() = lock.withLock { isEmptyImpl } in <lambda>()
35 lock.withLock { in offerInternal()
48 return@withLock in offerInternal()
63 lock.withLock { in offerSelectInternal()
72 return@withLock in offerSelectInternal()
96 lock.withLock { in pollInternal()
107 lock.withLock { in pollSelectInternal()
119 lock.withLock { in onCancelIdempotent()
134 override fun enqueueReceiveInternal(receive: Receive<E>): Boolean = lock.withLock { in <lambda>()
|
| D | ArrayChannel.kt | 52 override val isFull: Boolean get() = lock.withLock { isFullImpl } in <lambda>()
53 override val isEmpty: Boolean get() = lock.withLock { isEmptyImpl } in <lambda>()
54 override val isClosedForReceive: Boolean get() = lock.withLock { super.isClosedForReceive } in <lambda>()
59 lock.withLock { in offerInternal()
76 return@withLock in offerInternal()
91 lock.withLock { in offerSelectInternal()
105 return@withLock in offerSelectInternal()
130 override fun enqueueSend(send: Send): Any? = lock.withLock { in <lambda>()
182 lock.withLock { in pollInternal()
222 lock.withLock { in pollSelectInternal()
[all …]
|
| D | ArrayBroadcastChannel.kt | 94 bufferLock.withLock { in offerInternal()
111 bufferLock.withLock { in offerSelectInternal()
146 bufferLock.withLock { in updateHead()
181 return@withLock // go out of lock to wakeup this sender in updateHead()
227 subLock.withLock { in elementAt()
277 val result = subLock.withLock { in elementAt()
306 val result = subLock.withLock { in elementAt()
|
| /external/kotlinx.atomicfu/atomicfu/src/commonTest/kotlin/kotlinx/atomicfu/test/ |
| D | SimpleLockTest.kt | 12 fun withLock() { in <lambda>() method in kotlinx.atomicfu.test.SimpleLockTest
14 val result = lock.withLock { in <lambda>()
24 fun <T> withLock(block: () -> T): T { in withLock() method in kotlinx.atomicfu.test.SimpleLock
|
| D | ReentrantLockFieldTest.kt | 12 lock.withLock { in testLock()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | Concurrent.kt | 10 import kotlin.concurrent.withLock as withLockJvm
17 internal actual inline fun <T> ReentrantLock.withLock(action: () -> T) = this.withLockJvm(action) in subscriberList() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/ |
| D | MutexTest.kt | 55 mutex.withLock { in <lambda>()
68 mutex.withLock { in testUnconfinedStackOverflow()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/test/ |
| D | TaskTest.kt | 79 lock.withLock { 42 } in <lambda>()
136 lock.withLock { throw TestException("something went wrong") } in <lambda>()
|
| /external/kotlinx.atomicfu/atomicfu/src/commonTest/kotlin/bytecode_test/ |
| D | ReentrantLockTest.kt | 12 lock.withLock { in testLockField()
|
| /external/kotlinx.atomicfu/atomicfu/src/commonMain/kotlin/kotlinx/atomicfu/locks/ |
| D | Synchronized.common.kt | 13 public expect inline fun <T> ReentrantLock.withLock(block: () -> T): T method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/internal/ |
| D | Concurrent.kt | 9 internal actual inline fun <T> ReentrantLock.withLock(action: () -> T) = action() in withLock() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/internal/ |
| D | Concurrent.kt | 9 internal actual inline fun <T> ReentrantLock.withLock(action: () -> T) = action() in withLock() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | Concurrent.common.kt | 22 internal expect inline fun <T> ReentrantLock.withLock(action: () -> T): T method
|
| /external/kotlinx.atomicfu/atomicfu/src/jsMain/kotlin/kotlinx/atomicfu/locks/ |
| D | Synchronized.kt | 18 public actual inline fun <T> ReentrantLock.withLock(block: () -> T) = block() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-sync-06.kt | 34 mutex.withLock { in <lambda>()
|
| /external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/locks/ |
| D | Synchronized.kt | 15 public actual inline fun <T> ReentrantLock.withLock(block: () -> T): T { in reentrantLock() method
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
| D | FutureTest.kt | 217 lock.withLock { 42 } in <lambda>()
259 lock.withLock { throw TestException("something went wrong") } in <lambda>()
|
| /external/kotlinx.atomicfu/atomicfu/src/nativeMain/kotlin/kotlinx/atomicfu/locks/ |
| D | Synchronized.kt | 163 public actual inline fun <T> ReentrantLock.withLock(block: () -> T): T { in lock() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Mutex.kt | 109 public suspend inline fun <T> Mutex.withLock(owner: Any? = null, action: () -> T): T { in Mutex() method
|
| /external/dokka/ |
| D | package-list | 61 …dokka.location:kotlin.concurrent$withLock(java.util.concurrent.locks.Lock, kotlin.Function0((kotli…
|
| /external/kotlinx.coroutines/site/ |
| D | stdlib.package.list | 61 …dokka.location:kotlin.concurrent$withLock(java.util.concurrent.locks.Lock, kotlin.Function0((kotli…
|
| /external/kotlinx.atomicfu/ |
| D | README.md | 297 use `lock`/`tryLock`/`unlock` functions or `lock.withLock { ... }` extension function similarly to …
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 914 * `withLock` and `consumeEach` functions are now inline suspend functions.
1023 * Renamed `Mutex.withMutex` to `Mutex.withLock`, old name is deprecated.
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 1283 …public static final fun withLock (Lkotlinx/coroutines/sync/Mutex;Ljava/lang/Object;Lkotlin/jvm/fun…
1284 …public static synthetic fun withLock$default (Lkotlinx/coroutines/sync/Mutex;Ljava/lang/Object;Lko…
|