Searched refs:TaskQueue (Results 1 – 13 of 13) sorted by relevance
14 TaskQueue::TaskQueue() : process_queue_semaphore_(0), terminated_(false) {} in TaskQueue() function in v8::platform::TaskQueue17 TaskQueue::~TaskQueue() { in ~TaskQueue()24 void TaskQueue::Append(Task* task) { in Append()32 Task* TaskQueue::GetNext() { in GetNext()51 void TaskQueue::Terminate() { in Terminate()58 void TaskQueue::BlockUntilQueueEmptyForTesting() { in BlockUntilQueueEmptyForTesting()
22 class V8_PLATFORM_EXPORT TaskQueue {24 TaskQueue();25 ~TaskQueue();47 DISALLOW_COPY_AND_ASSIGN(TaskQueue);
19 class TaskQueue; variable23 explicit WorkerThread(TaskQueue* queue); in NON_EXPORTED_BASE()32 TaskQueue* queue_; in NON_EXPORTED_BASE()
25 class TaskQueue; variable85 TaskQueue queue_; in NON_EXPORTED_BASE()
13 WorkerThread::WorkerThread(TaskQueue* queue) in WorkerThread()
53 int ReloadWorkQueue(TaskQueue* work_queue);90 TaskQueue incoming_queue_;
492 TaskQueue work_queue_;513 TaskQueue deferred_non_nestable_work_queue_;
96 int IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) { in ReloadWorkQueue()
66 typedef de::ThreadSafeRingBuffer<Task*> TaskQueue; typedef71 TaskExecutorThread (TaskQueue& tasks) in TaskExecutorThread()91 TaskQueue& m_tasks;107 TaskQueue m_tasks;
38 import vogar.tasks.TaskQueue;104 public final TaskQueue taskQueue;188 this.taskQueue = new TaskQueue(console, maxConcurrentActions); in Run()
33 public final class TaskQueue { class44 public TaskQueue(Console console, int maxConcurrentActions) { in TaskQueue() method in TaskQueue
51 using TaskQueue = std::queue<PendingTask>; variable
87 TaskQueue pending_tasks_;