Searched refs:_delayed (Results 1 – 1 of 1) sorted by relevance
185 private val _delayed = atomic<DelayedTaskQueue?>(null) constant in kotlinx.coroutines.EventLoopImplBase194 val delayed = _delayed.value213 val nextDelayedTask = _delayed.value?.peek() ?: return Long.MAX_VALUE262 val delayed = _delayed.value in processNextEvent()374 private fun shouldUnpark(task: DelayedTask): Boolean = _delayed.value?.peek() === task in shouldUnpark()378 val delayedQueue = _delayed.value ?: run { in shouldUnpark()379 _delayed.compareAndSet(null, DelayedTaskQueue(now)) in shouldUnpark()380 _delayed.value!! in shouldUnpark()388 _delayed.value = null in resetAll()402 val delayedTask = _delayed.value?.removeFirstOrNull() ?: break in rescheduleAllDelayed()