| /external/autotest/scheduler/ |
| D | thread_lib_unittest.py | 61 task_queue = thread_lib.ThreadedTaskQueue()
70 task_queue.worker(drone, task_queue.results_queue)
71 result = task_queue.results_queue.get()
73 self.assertTrue(task_queue.results_queue.empty() and
105 task_queue = thread_lib.ThreadedTaskQueue()
114 task_queue.drone_threads[drone1] = waiting_worker
115 task_queue.drone_threads[drone2] = failing_worker
117 target=task_queue.wait_on_drones)
131 self.assertTrue(task_queue.drone_threads == {})
135 task_queue.drone_threads[drone1] = quick_worker
[all …]
|
| D | drone_task_queue_unittest.py | 62 task_queue = drone_task_queue.DroneTaskQueue()
63 task_queue.results[drone1] = None
65 task_queue.execute, [])
66 task_queue.results.clear()
82 task_queue.execute(drones, wait=False)
83 self.assertTrue(set(task_queue.results.keys()) == set(drones))
84 results = task_queue.get_results()
85 self.assertTrue(len(task_queue.results) == 0)
97 self.assertTrue(task_queue.execute(drones, wait=True)[drone1] ==
99 self.assertTrue(len(task_queue.results) == 0)
[all …]
|
| /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
|