Searched refs:TaskQueue (Results 1 – 10 of 10) sorted by relevance
15 TaskQueue::TaskQueue() : process_queue_semaphore_(0), terminated_(false) {} in TaskQueue() function in v8::platform::TaskQueue18 TaskQueue::~TaskQueue() { in ~TaskQueue()24 void TaskQueue::Append(std::unique_ptr<Task> task) { in Append()31 std::unique_ptr<Task> TaskQueue::GetNext() { in GetNext()50 void TaskQueue::Terminate() { in Terminate()57 void TaskQueue::BlockUntilQueueEmptyForTesting() { in BlockUntilQueueEmptyForTesting()
23 class V8_PLATFORM_EXPORT TaskQueue {25 TaskQueue();26 ~TaskQueue();28 TaskQueue(const TaskQueue&) = delete;29 TaskQueue& operator=(const TaskQueue&) = delete;
19 class TaskQueue; variable23 explicit WorkerThread(TaskQueue* queue); in NON_EXPORTED_BASE()33 TaskQueue* queue_; in NON_EXPORTED_BASE()
13 WorkerThread::WorkerThread(TaskQueue* queue) in WorkerThread()
34 class TaskQueue {42 explicit Task(Callable C, TaskQueue &Parent) in Task()64 TaskQueue *Parent;69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() function72 ~TaskQueue() { in ~TaskQueue()
20 TaskQueue<Task>* task_queue;31 TaskQueue<Task>* pending_worker_tasks = worker_data->task_queue; in PlatformWorkerThread()59 explicit DelayedTaskScheduler(TaskQueue<Task>* tasks) in DelayedTaskScheduler()165 TaskQueue<Task>* pending_worker_tasks_;167 TaskQueue<Task> tasks_;573 TaskQueue<T>::TaskQueue() in TaskQueue() function in node::TaskQueue578 void TaskQueue<T>::Push(std::unique_ptr<T> task) { in Push()586 std::unique_ptr<T> TaskQueue<T>::Pop() { in Pop()597 std::unique_ptr<T> TaskQueue<T>::BlockingPop() { in BlockingPop()611 void TaskQueue<T>::NotifyOfCompletion() { in NotifyOfCompletion()[all …]
23 class TaskQueue {25 TaskQueue();26 ~TaskQueue() = default;106 TaskQueue<v8::Task> foreground_tasks_;107 TaskQueue<DelayedTask> foreground_delayed_tasks_;130 TaskQueue<v8::Task> pending_worker_tasks_;
124 using TaskQueue = std::vector<Task>; in MultiQueueTaskExecutor() typedef131 std::vector<TaskQueue> taskQueues(numQueues); in MultiQueueTaskExecutor()
66 typedef de::ThreadSafeRingBuffer<Task*> TaskQueue; typedef71 TaskExecutorThread (TaskQueue& tasks) in TaskExecutorThread()91 TaskQueue& m_tasks;107 TaskQueue m_tasks;
320 using TaskQueue = containers::deque<Task>; variable440 GUARDED_BY(mutex) TaskQueue tasks;