Searched refs:singleConsumer (Results 1 – 7 of 7) sorted by relevance
19 val singleConsumer: Boolean constant in kotlinx.coroutines.lincheck.AbstractLockFreeTaskQueueWithoutRemoveLincheckTest22 protected val q = LockFreeTaskQueue<Int>(singleConsumer = singleConsumer)37 …thRemoveLincheckTest : AbstractLockFreeTaskQueueWithoutRemoveLincheckTest(singleConsumer = false) { in close()43 …ithRemoveLincheckTest : AbstractLockFreeTaskQueueWithoutRemoveLincheckTest(singleConsumer = true) {
31 … singleConsumer: Boolean // true when there is only a single consumer (slightly faster & lock-free) in <lambda>()33 private val _cur = atomic(Core<E>(Core.INITIAL_CAPACITY, singleConsumer)) in <lambda>()78 … private val singleConsumer: Boolean // true when there is only a single consumer (slightly faster) constant in LockFreeTaskQueueCore114 if (!singleConsumer && array[tail and mask].value != null) { in addLast()172 if (singleConsumer) return null // consider it not added yet in removeFirstOrNull()187 if (!singleConsumer) return@loop in removeFirstOrNull()230 val next = LockFreeTaskQueueCore<E>(capacity * 2, singleConsumer) in allocateNextCopy()
35 private val queue = LockFreeTaskQueue<Runnable>(singleConsumer = false) in <lambda>()
14 private val singleConsumer: Boolean in <lambda>() constant in kotlinx.coroutines.internal.LockFreeTaskQueueTest27 val q = LockFreeTaskQueue<Int>(singleConsumer) in <lambda>()65 val q = LockFreeTaskQueue<Int>(singleConsumer) in <lambda>()
26 private val singleConsumer = nConsumers == 1 in <lambda>() constant50 queue.value = LockFreeTaskQueue(singleConsumer) in <lambda>()72 if (singleConsumer) { in <lambda>()
114 internal class GlobalQueue : LockFreeTaskQueue<Task>(singleConsumer = false) in toString()
314 … val newQueue = Queue<Runnable>(Queue.INITIAL_CAPACITY, singleConsumer = true) in enqueueImpl()355 … val newQueue = Queue<Runnable>(Queue.INITIAL_CAPACITY, singleConsumer = true) in closeQueue()