Searched refs:DelayedTaskQueue (Results 1 – 3 of 3) sorted by relevance
184 private val _delayed = atomic<DelayedTaskQueue?>(null)373 _delayed.compareAndSet(null, DelayedTaskQueue(now)) in shouldUnpark()431 fun scheduleTask(now: Long, delayed: DelayedTaskQueue, eventLoop: EventLoopImplBase): Int { in timeToExecute()478 (heap as? DelayedTaskQueue)?.remove(this) // remove if it is in heap (first) in dispose()516 internal class DelayedTaskQueue( in toString() class
64 using DelayedTaskQueue = std::priority_queue<base::PendingTask>; variable
192 DelayedTaskQueue queue_;