Searched refs:TimedRunnable (Results 1 – 1 of 1) sorted by relevance
39 private val queue = ThreadSafeHeap<TimedRunnable>() in <lambda>()83 queue.addLast(TimedRunnable(block, _counter.getAndIncrement())) in <lambda>()86 TimedRunnable(block, _counter.getAndIncrement(), safePlus(currentTime, delayTime)) in <lambda>()168 val pendingTasks = mutableListOf<TimedRunnable>() in <lambda>()200 private class TimedRunnable( in run() class204 ) : Comparable<TimedRunnable>, Runnable by runnable, ThreadSafeHeapNode { in run()208 override fun compareTo(other: TimedRunnable) = if (time == other.time) { in run()