Home
last modified time | relevance | path

Searched refs:consumerIndex (Results 1 – 2 of 2) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/
DWorkQueue.kt52 internal val bufferSize: Int get() = producerIndex.value - consumerIndex.value
58 private val consumerIndex = atomic(0) constant
121 var start = victim.consumerIndex.value in tryStealBlockingFrom()
182 val tailLocal = consumerIndex.value in pollBuffer()
185 if (consumerIndex.compareAndSet(tailLocal, tailLocal + 1)) { in pollBuffer()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DSharedFlowStressTest.kt58 jobs += List(nConsumers) { consumerIndex -> in <lambda>() method
62 .dropWhile { it % nConsumers != consumerIndex.toLong() } in <lambda>()
65 check(it % nConsumers == consumerIndex.toLong()) in <lambda>()