Searched refs:task_queue_ (Results 1 – 10 of 10) sorted by relevance
| /third_party/flutter/engine/flutter/fml/ |
| D | message_loop_impl.cc | 47 : task_queue_(MessageLoopTaskQueues::GetInstance()), in MessageLoopImpl()
48 queue_id_(task_queue_->CreateTaskQueue()), in MessageLoopImpl()
50 task_queue_->SetWakeable(queue_id_, this); in MessageLoopImpl()
54 task_queue_->Dispose(queue_id_); in ~MessageLoopImpl()
65 task_queue_->RegisterTask(queue_id_, task, target_time); in PostTask()
74 task_queue_->AddTaskObserver(queue_id_, key, callback); in AddTaskObserver()
84 task_queue_->RemoveTaskObserver(queue_id_, key); in RemoveTaskObserver()
110 task_queue_->DisposeTasks(queue_id_); in DoRun()
122 task_queue_->GetTasksToRunNow(queue_id_, type, invocations); in FlushTasks()
127 task_queue_->GetObserversToNotify(queue_id_); in FlushTasks()
|
| D | message_loop_impl.h | 63 fml::RefPtr<MessageLoopTaskQueues> task_queue_;
|
| /third_party/gn/src/util/ |
| D | msg_loop.cc | 36 return (!task_queue_.empty()) || should_quit_; in Run()
42 task = std::move(task_queue_.front()); in Run()
43 task_queue_.pop(); in Run()
57 task_queue_.emplace(std::move(work)); in PostTask()
68 task = std::move(task_queue_.front()); in RunUntilIdleForTesting()
69 task_queue_.pop(); in RunUntilIdleForTesting()
71 if (task_queue_.empty()) in RunUntilIdleForTesting()
|
| D | worker_pool.cc | 124 task_queue_.emplace(std::move(work)); in PostTask()
138 return (!task_queue_.empty()) || should_stop_processing_; in Worker()
141 if (should_stop_processing_ && task_queue_.empty()) in Worker()
144 task = std::move(task_queue_.front()); in Worker()
145 task_queue_.pop(); in Worker()
|
| D | msg_loop.h | 38 std::queue<std::function<void()>> task_queue_; variable
|
| D | worker_pool.h | 28 std::queue<std::function<void()>> task_queue_; variable
|
| /third_party/flutter/engine/flutter/shell/platform/glfw/ |
| D | glfw_event_loop.cc | 32 while (!task_queue_.empty()) { in WaitForEvents()
33 const auto& top = task_queue_.top(); in WaitForEvents()
44 expired_tasks.push_back(task_queue_.top().task); in WaitForEvents()
47 task_queue_.pop(); in WaitForEvents()
67 const auto next_wake = task_queue_.empty() ? TaskTimePoint::max() in WaitForEvents()
68 : task_queue_.top().fire_time; in WaitForEvents()
103 task_queue_.push(task); in PostTask()
|
| D | glfw_event_loop.h | 61 std::priority_queue<Task, std::deque<Task>, Task::Comparer> task_queue_; variable
|
| /third_party/node/src/ |
| D | node_platform.cc | 550 outstanding_tasks_(0), stopped_(false), task_queue_() { } in TaskQueue()
556 task_queue_.push(std::move(task)); in Push()
563 if (task_queue_.empty()) { in Pop()
566 std::unique_ptr<T> result = std::move(task_queue_.front()); in Pop()
567 task_queue_.pop(); in Pop()
574 while (task_queue_.empty() && !stopped_) { in BlockingPop()
580 std::unique_ptr<T> result = std::move(task_queue_.front()); in BlockingPop()
581 task_queue_.pop(); in BlockingPop()
612 result.swap(task_queue_); in PopAll()
|
| D | node_platform.h | 42 std::queue<std::unique_ptr<T>> task_queue_; variable
|