| /external/cronet/stable/base/task/thread_pool/ |
| D | delayed_task_manager.h | 71 struct DelayedTask { struct
72 DelayedTask();
73 DelayedTask(Task task, PostTaskNowCallback callback);
74 DelayedTask(DelayedTask&& other);
75 DelayedTask(const DelayedTask&) = delete;
76 DelayedTask& operator=(const DelayedTask&) = delete; argument
77 ~DelayedTask();
80 DelayedTask& operator=(DelayedTask&& other); argument
83 bool operator>(const DelayedTask& other) const;
129 IntrusiveHeap<DelayedTask, std::greater<>> delayed_task_queue_
|
| D | delayed_task_manager.cc | 22 DelayedTaskManager::DelayedTask::DelayedTask() = default;
24 DelayedTaskManager::DelayedTask::DelayedTask(Task task, in DelayedTask() function in base::internal::DelayedTaskManager::DelayedTask
28 DelayedTaskManager::DelayedTask::DelayedTask(
29 DelayedTaskManager::DelayedTask&& other) = default;
31 DelayedTaskManager::DelayedTask::~DelayedTask() = default;
33 DelayedTaskManager::DelayedTask& DelayedTaskManager::DelayedTask::operator=(
34 DelayedTaskManager::DelayedTask&& other) = default;
36 bool DelayedTaskManager::DelayedTask::operator>( in operator >()
37 const DelayedTask& other) const { in operator >()
102 DelayedTask(std::move(task), std::move(post_task_now_callback))); in AddDelayedTask()
[all …]
|
| /external/cronet/tot/base/task/thread_pool/ |
| D | delayed_task_manager.h | 71 struct DelayedTask { struct
72 DelayedTask();
73 DelayedTask(Task task, PostTaskNowCallback callback);
74 DelayedTask(DelayedTask&& other);
75 DelayedTask(const DelayedTask&) = delete;
76 DelayedTask& operator=(const DelayedTask&) = delete; argument
77 ~DelayedTask();
80 DelayedTask& operator=(DelayedTask&& other); argument
83 bool operator>(const DelayedTask& other) const;
129 IntrusiveHeap<DelayedTask, std::greater<>> delayed_task_queue_
|
| D | delayed_task_manager.cc | 22 DelayedTaskManager::DelayedTask::DelayedTask() = default;
24 DelayedTaskManager::DelayedTask::DelayedTask(Task task, in DelayedTask() function in base::internal::DelayedTaskManager::DelayedTask
28 DelayedTaskManager::DelayedTask::DelayedTask(
29 DelayedTaskManager::DelayedTask&& other) = default;
31 DelayedTaskManager::DelayedTask::~DelayedTask() = default;
33 DelayedTaskManager::DelayedTask& DelayedTaskManager::DelayedTask::operator=(
34 DelayedTaskManager::DelayedTask&& other) = default;
36 bool DelayedTaskManager::DelayedTask::operator>( in operator >()
37 const DelayedTask& other) const { in operator >()
102 DelayedTask(std::move(task), std::move(post_task_now_callback))); in AddDelayedTask()
[all …]
|
| /external/ot-br-posix/src/common/ |
| D | task_runner.hpp | 140 struct DelayedTask struct in otbr::TaskRunner
146 … bool operator()(const DelayedTask &aLhs, const DelayedTask &aRhs) const { return aRhs < aLhs; } in operator ()()
149 DelayedTask(TaskId aTaskId, Milliseconds aDelay, Task<void> aTask) in DelayedTask() function
156 bool operator<(const DelayedTask &aOther) const in operator <() argument
175 std::priority_queue<DelayedTask, std::vector<DelayedTask>, DelayedTask::Comparator> mTaskQueue;
|
| D | task_runner.cpp | 46 : mTaskQueue(DelayedTask::Comparator{}) in TaskRunner()
185 const DelayedTask &top = mTaskQueue.top(); in PopTasks()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 174 protected fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) in delayNanosToMillis()
369 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, SynchronizedObject() {
430 override fun compareTo(other: DelayedTask): Int { in compareTo()
496 ) : DelayedTask(nanoTime) { in toString()
504 ) : DelayedTask(nanoTime) {
526 ) : 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/jsAndWasmJsShared/src/ |
| D | EventLoop.kt | 15 …protected actual fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask): Unit = uns… in unpark()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | EventLoop.kt | 17 protected actual fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) { in reschedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/ |
| D | ThreadSafeHeapStressTest.kt | 10 private class DisposableNode : EventLoopImplBase.DelayedTask(1L) {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | EventLoop.kt | 17 protected actual open fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) { in reschedule()
|
| D | DefaultExecutor.kt | 69 override fun reschedule(now: Long, delayedTask: DelayedTask) { in reschedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/wasmWasi/src/ |
| D | EventLoop.kt | 63 protected actual fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) { in invokeOnTimeout()
|