Searched refs:DelayedTask (Results 1 – 9 of 9) sorted by relevance
| /external/webrtc/modules/utility/source/ |
| D | process_thread_impl.h | 69 struct DelayedTask { struct
70 DelayedTask(int64_t run_at_ms, std::unique_ptr<QueuedTask> task) in DelayedTask() function
72 friend bool operator<(const DelayedTask& lhs, const DelayedTask& rhs) {
105 std::priority_queue<DelayedTask> delayed_tasks_ RTC_GUARDED_BY(lock_); argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 181 protected fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) in delayNanosToMillis()
369 public fun schedule(now: Long, delayedTask: DelayedTask) { in schedule()
378 private fun shouldUnpark(task: DelayedTask): Boolean = _delayed.value?.peek() === task in shouldUnpark()
380 private fun scheduleImpl(now: Long, delayedTask: DelayedTask): Int { in shouldUnpark()
411 internal abstract class DelayedTask( class in kotlinx.coroutines.EventLoopImplBase
417 ) : Runnable, Comparable<DelayedTask>, DisposableHandle, ThreadSafeHeapNode {
430 override fun compareTo(other: DelayedTask): Int { in compareTo()
499 ) : DelayedTask(nanoTime) { in toString()
507 ) : DelayedTask(nanoTime) {
529 ) : ThreadSafeHeap<DelayedTask>() in toString()
|
| /external/libbrillo/brillo/message_loops/ |
| D | base_message_loop.h | 78 struct DelayedTask { struct
90 std::map<MessageLoop::TaskId, DelayedTask> delayed_tasks_; argument
|
| D | base_message_loop.cc | 96 DelayedTask{from_here, task_id, std::move(task)}); in PostDelayedTask()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | EventLoop.kt | 16 protected actual open fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) { in reschedule()
|
| D | DefaultExecutor.kt | 72 override fun reschedule(now: Long, delayedTask: DelayedTask) { in reschedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | EventLoop.kt | 19 …protected actual fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask): Unit = uns… in unpark()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | EventLoop.kt | 23 protected actual fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) { in reschedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/ |
| D | ThreadSafeHeapStressTest.kt | 13 private class DisposableNode : EventLoopImplBase.DelayedTask(1L) {
|