Home
last modified time | relevance | path

Searched refs:task_queue (Results 1 – 6 of 6) sorted by relevance

/external/autotest/scheduler/
Dthread_lib_unittest.py61 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 …]
Ddrone_task_queue_unittest.py62 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/python/cpython2/Doc/includes/
Dmp_workers.py59 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/
Dpipeline_process.py40 def __init__(self, num_processes, name, cache, stage, task_queue, helper, argument
64 self._task_queue = task_queue
/external/valgrind/drd/scripts/
Ddownload-and-build-splash2.in145 + i < sizeof(global->task_queue) / sizeof(global->task_queue[0]);
148 + DRD_IGNORE_VAR(global->task_queue[i].n_tasks);
/external/libmojo/mojo/edk/system/ports/
Dports_unittest.cc94 std::priority_queue<Task*, std::vector<Task*>, TaskComparator> task_queue; variable
106 while (!task_queue.empty()) { in PumpTasks()
107 Task* task = task_queue.top(); in PumpTasks()
108 task_queue.pop(); in PumpTasks()
119 while (!task_queue.empty()) { in PumpUntilTask()
120 Task* task = task_queue.top(); in PumpUntilTask()
126 task_queue.pop(); in PumpUntilTask()
137 while (!task_queue.empty()) { in DiscardPendingTasks()
138 Task* task = task_queue.top(); in DiscardPendingTasks()
139 task_queue.pop(); in DiscardPendingTasks()
[all …]