Searched refs:work_queue (Results 1 – 5 of 5) sorted by relevance
| /external/v8/tools/testrunner/local/ |
| D | pool.py | 44 def Worker(fn, work_queue, done_queue, done, argument
53 for args in iter(work_queue.get, "STOP"):
89 self.work_queue = Queue()
117 self.work_queue,
151 self.work_queue.put(gen.next())
163 self.work_queue.put(args)
178 self.work_queue.put("STOP")
185 while True: self.work_queue.get(False)
|
| /external/chromium-trace/catapult/perf_insights/perf_insights/endpoints/cloud_mapper/ |
| D | worker.py | 33 work_queue = queue.Queue()
35 work_queue.put(t)
40 while not work_queue.empty():
41 trace_url = work_queue.get()
58 work_queue.task_done()
64 work_queue.join()
|
| /external/libchrome/base/message_loop/ |
| D | incoming_task_queue.cc | 90 int IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) { in ReloadWorkQueue() argument
92 DCHECK(work_queue->empty()); in ReloadWorkQueue()
102 incoming_queue_.Swap(work_queue); in ReloadWorkQueue()
|
| D | incoming_task_queue.h | 52 int ReloadWorkQueue(TaskQueue* work_queue);
|
| /external/llvm/utils/ |
| D | llvm-compilers-check | 255 def __init__(self, work_queue, jobs, argument
259 self.work_queue = work_queue
274 source, build = self.work_queue.get()
279 self.work_queue.task_done()
595 work_queue = queue.Queue() variable
611 builder = Builder(work_queue, jobs,
619 work_queue.put((source, build))
621 work_queue.join()
|