| /external/libchrome/base/task/sequence_manager/ |
| D | sequence_manager_impl.cc | 157 std::unique_ptr<internal::TaskQueueImpl> task_queue = in CreateTaskQueueImpl() local
159 main_thread_only().active_queues.insert(task_queue.get()); in CreateTaskQueueImpl()
160 main_thread_only().selector.AddQueue(task_queue.get()); in CreateTaskQueueImpl()
161 return task_queue; in CreateTaskQueueImpl()
169 internal::TaskQueueImpl* task_queue, in AddToIncomingImmediateWorkList() argument
173 if (task_queue->immediate_work_list_storage()->queue) in AddToIncomingImmediateWorkList()
177 task_queue->immediate_work_list_storage()->queue = task_queue; in AddToIncomingImmediateWorkList()
178 task_queue->immediate_work_list_storage()->order = enqueue_order; in AddToIncomingImmediateWorkList()
179 task_queue->immediate_work_list_storage()->next = in AddToIncomingImmediateWorkList()
182 task_queue->immediate_work_list_storage(); in AddToIncomingImmediateWorkList()
[all …]
|
| D | task_queue_selector_unittest.cc | 137 queue_to_index_map_.find(chosen_work_queue->task_queue())->second; in PopTasks()
152 std::unique_ptr<TaskQueueImpl> task_queue = in SetUp() local
155 selector_.AddQueue(task_queue.get()); in SetUp()
156 task_queues_.push_back(std::move(task_queue)); in SetUp()
167 for (std::unique_ptr<TaskQueueImpl>& task_queue : task_queues_) { in TearDown()
171 selector_.RemoveQueue(task_queue.get()); in TearDown()
172 task_queue->UnregisterTaskQueue(); in TearDown()
373 EXPECT_EQ(task_queues_[3].get(), chosen_work_queue->task_queue()); in TEST_F()
390 queue_to_index_map_.find(chosen_work_queue->task_queue())->second; in TEST_F()
410 queue_to_index_map_.find(chosen_work_queue->task_queue())->second; in TEST_F()
[all …]
|
| D | sequence_manager_impl.h | 134 std::unique_ptr<internal::TaskQueueImpl> task_queue);
175 internal::TaskQueueImpl* task_queue, in ExecutingTask()
178 task_queue(task_queue), in ExecutingTask()
182 internal::TaskQueueImpl* task_queue = nullptr; member
271 bool AddToIncomingImmediateWorkList(internal::TaskQueueImpl* task_queue,
273 void RemoveFromIncomingImmediateWorkList(internal::TaskQueueImpl* task_queue);
292 internal::TaskQueueImpl* task_queue);
|
| D | graceful_queue_shutdown_helper.cc | 19 std::unique_ptr<internal::TaskQueueImpl> task_queue) { in GracefullyShutdownTaskQueue() argument
23 queues_.push_back(std::move(task_queue)); in GracefullyShutdownTaskQueue()
|
| D | work_queue.h | 36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type);
91 TaskQueueImpl* task_queue() const { return task_queue_; } in task_queue() function
|
| D | sequence_manager_impl_unittest.cc | 371 scoped_refptr<TestTaskQueue> task_queue) { in InsertFenceAndPostTestTask() argument
373 task_queue->InsertFence(TaskQueue::InsertFencePosition::kNow); in InsertFenceAndPostTestTask()
374 task_queue->PostTask(FROM_HERE, BindOnce(&TestTask, id + 1, run_order)); in InsertFenceAndPostTestTask()
378 task_queue->GetTaskQueueImpl()->ReloadImmediateWorkQueueIfEmpty(); in InsertFenceAndPostTestTask()
856 scoped_refptr<TestTaskQueue> task_queue, in RecordTimeAndQueueTask() argument
858 run_times->emplace_back(task_queue, clock->NowTicks()); in RecordTimeAndQueueTask()
1624 scoped_refptr<TaskQueue> task_queue = CreateTaskQueue(); in TEST_P() local
1636 BindOnce(&TaskQueue::ShutdownTaskQueue, Unretained(task_queue.get())), in TEST_P()
2047 QuadraticTask(scoped_refptr<TaskQueue> task_queue, in QuadraticTask() argument
2051 task_queue_(task_queue), in QuadraticTask()
[all …]
|
| D | task_queue_impl.cc | 114 TaskQueueImpl* task_queue, in MainThreadOnly() argument
119 new WorkQueue(task_queue, "delayed", WorkQueue::QueueType::kDelayed)), in MainThreadOnly()
120 immediate_work_queue(new WorkQueue(task_queue, in MainThreadOnly()
771 scoped_refptr<TaskQueue> task_queue) in QueueEnabledVoterImpl() argument
772 : task_queue_(task_queue), enabled_(true) {} in QueueEnabledVoterImpl()
857 TaskQueueImpl::CreateQueueEnabledVoter(scoped_refptr<TaskQueue> task_queue) { in CreateQueueEnabledVoter() argument
858 DCHECK_EQ(task_queue->GetTaskQueueImpl(), this); in CreateQueueEnabledVoter()
861 return std::make_unique<QueueEnabledVoterImpl>(task_queue); in CreateQueueEnabledVoter()
|
| D | task_queue_impl.h | 170 internal::TaskQueueImpl* task_queue; member
273 explicit QueueEnabledVoterImpl(scoped_refptr<TaskQueue> task_queue);
338 TaskQueueImpl* task_queue,
|
| D | work_queue.cc | 13 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() argument
16 : task_queue_(task_queue), name_(name), queue_type_(queue_type) {} in WorkQueue()
|
| /external/python/cpython3/Doc/includes/ |
| D | mp_workers.py | 46 task_queue = Queue()
51 task_queue.put(task)
55 Process(target=worker, args=(task_queue, done_queue)).start()
64 task_queue.put(task)
72 task_queue.put('STOP')
|
| /external/python/cpython2/Doc/includes/ |
| D | mp_workers.py | 59 task_queue = Queue()
64 task_queue.put(task)
68 Process(target=worker, args=(task_queue, done_queue)).start()
77 task_queue.put(task)
85 task_queue.put('STOP')
|
| /external/toolchain-utils/bestflags/ |
| D | pipeline_process.py | 40 def __init__(self, num_processes, name, cache, stage, task_queue, helper, argument
64 self._task_queue = task_queue
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | run_handler.cc | 179 Queue* task_queue = nullptr; in EnqueueTask() local
184 task_queue = &(non_blocking_work_queues_[queue_index]->queue); in EnqueueTask()
187 task_queue = &blocking_work_queue_; in EnqueueTask()
194 t = task_queue->PushFront(std::move(t)); in EnqueueTask()
|