Searched refs:singleConsumer (Results 1 – 6 of 6) sorted by relevance
18 …ractLockFreeTaskQueueWithoutRemoveLCStressTest protected constructor(singleConsumer: Boolean) : Ve…20 protected val q = LockFreeTaskQueue<Int>(singleConsumer = singleConsumer)41 …WithRemoveLCStressTest : AbstractLockFreeTaskQueueWithoutRemoveLCStressTest(singleConsumer = false)44 …eWithRemoveLCStressTest : AbstractLockFreeTaskQueueWithoutRemoveLCStressTest(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()
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>() constant in kotlinx.coroutines.internal.LockFreeTaskQueueStressTest50 queue.value = LockFreeTaskQueue(singleConsumer) in <lambda>()72 if (singleConsumer) { in <lambda>()
109 internal class GlobalQueue : LockFreeTaskQueue<Task>(singleConsumer = false) in toString()
308 … val newQueue = Queue<Runnable>(Queue.INITIAL_CAPACITY, singleConsumer = true) in enqueueImpl()349 … val newQueue = Queue<Runnable>(Queue.INITIAL_CAPACITY, singleConsumer = true) in closeQueue()