Searched refs:consumerIndex (Results 1 – 2 of 2) sorted by relevance
52 internal val bufferSize: Int get() = producerIndex.value - consumerIndex.value58 private val consumerIndex = atomic(0) constant in kotlinx.coroutines.scheduling.WorkQueue121 var start = victim.consumerIndex.value in tryStealBlockingFrom()182 val tailLocal = consumerIndex.value in pollBuffer()185 if (consumerIndex.compareAndSet(tailLocal, tailLocal + 1)) { in pollBuffer()
58 jobs += List(nConsumers) { consumerIndex -> in <lambda>() method62 .dropWhile { it % nConsumers != consumerIndex.toLong() } in <lambda>()65 check(it % nConsumers == consumerIndex.toLong()) in <lambda>()