Home
last modified time | relevance | path

Searched refs:task_queue_ (Results 1 - 12 of 12) sorted by relevance

/third_party/gn/src/util/
H A Dmsg_loop.cc36 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()
H A Dworker_pool.cc71 task_queue_.emplace(std::move(work)); in PostTask()
85 return (!task_queue_.empty()) || should_stop_processing_; in Worker()
88 if (should_stop_processing_ && task_queue_.empty()) in Worker()
91 task = std::move(task_queue_.front()); in Worker()
92 task_queue_.pop(); in Worker()
H A Dmsg_loop.h38 std::queue<std::function<void()>> task_queue_; member in MsgLoop
H A Dworker_pool.h28 std::queue<std::function<void()>> task_queue_; member in WorkerPool
/third_party/node/deps/v8/src/libplatform/
H A Dtask-queue.cc21 DCHECK(task_queue_.empty()); in ~TaskQueue()
27 task_queue_.push(std::move(task)); in Append()
35 if (!task_queue_.empty()) { in GetNext()
36 std::unique_ptr<Task> result = std::move(task_queue_.front()); in GetNext()
37 task_queue_.pop(); in GetNext()
61 if (task_queue_.empty()) return; in BlockUntilQueueEmptyForTesting()
H A Ddefault-foreground-task-runner.cc34 while (!task_queue_.empty()) task_queue_.pop_front(); in Terminate()
43 task_queue_.push_back(std::make_pair(nestability, std::move(task))); in PostTaskLocked()
100 if (nesting_depth_ == 0) return !task_queue_.empty(); in HasPoppableTaskInQueue()
101 for (auto it = task_queue_.cbegin(); it != task_queue_.cend(); it++) { in HasPoppableTaskInQueue()
129 auto it = task_queue_.begin(); in PopTaskFromQueue()
130 for (; it != task_queue_.end(); it++) { in PopTaskFromQueue()
135 DCHECK(it != task_queue_.end()); in PopTaskFromQueue()
137 task_queue_ in PopTaskFromQueue()
[all...]
H A Ddelayed-task-queue.cc20 DCHECK(task_queue_.empty()); in ~DelayedTaskQueue()
30 task_queue_.push(std::move(task)); in Append()
53 task_queue_.push(std::move(task)); in GetNext()
56 if (!task_queue_.empty()) { in GetNext()
57 std::unique_ptr<Task> result = std::move(task_queue_.front()); in GetNext()
58 task_queue_.pop(); in GetNext()
67 if (task_queue_.empty() && !delayed_task_queue_.empty()) { in GetNext()
H A Dtask-queue.h48 std::queue<std::unique_ptr<Task>> task_queue_; member in v8::platform::TaskQueue
H A Ddelayed-task-queue.h61 std::queue<std::unique_ptr<Task>> task_queue_; member in v8::platform::DelayedTaskQueue
H A Ddefault-foreground-task-runner.h96 std::deque<TaskQueueEntry> task_queue_;
/third_party/node/src/
H A Dnode_platform.cc575 outstanding_tasks_(0), stopped_(false), task_queue_() { } in TaskQueue()
581 task_queue_.push(std::move(task)); in Push()
588 if (task_queue_.empty()) { in Pop()
591 std::unique_ptr<T> result = std::move(task_queue_.front()); in Pop()
592 task_queue_.pop(); in Pop()
599 while (task_queue_.empty() && !stopped_) { in BlockingPop()
605 std::unique_ptr<T> result = std::move(task_queue_.front()); in BlockingPop()
606 task_queue_.pop(); in BlockingPop()
637 result.swap(task_queue_); in PopAll()
H A Dnode_platform.h42 std::queue<std::unique_ptr<T>> task_queue_; member in node::TaskQueue

Completed in 6 milliseconds