Searched refs:blockingTasksInBuffer (Results 1 – 1 of 1) sorted by relevance
60 private val blockingTasksInBuffer = atomic(0) constant83 if (task.isBlocking) blockingTasksInBuffer.incrementAndGet() in addLast()127 if (victim.blockingTasksInBuffer.value == 0) break in tryStealBlockingFrom()130 victim.blockingTasksInBuffer.decrementAndGet() in tryStealBlockingFrom()196 val value = blockingTasksInBuffer.decrementAndGet() in Task()