HomeSort by relevance Sort by last modified time
    Searched refs:result_queue (Results 1 - 8 of 8) sorted by null

  /external/toolchain-utils/bestflags/
pipeline_worker.py 21 def Helper(stage, done_dict, helper_queue, completed_queue, result_queue):
42 result_queue: After the results of the duplicate tasks have been resolved,
72 result_queue.put(task)
78 result_queue)
83 result_queue)
87 result_queue):
101 result_queue: After the results of the duplicate tasks have been resolved,
117 result_queue.put(duplicate_task)
121 def Worker(stage, task, helper_queue, result_queue):
133 result_queue: Queue that holds the completed tasks and the results. This i
    [all...]
pipeline_process_test.py 23 def MockHelper(stage, done_dict, helper_queue, _, result_queue):
36 result_queue.put(ERROR)
38 result_queue.put(('helper', task.GetIdentifier(TEST_STAGE)))
41 def MockWorker(stage, task, _, result_queue):
43 result_queue.put(('worker', task.GetIdentifier(TEST_STAGE)))
steering.py 14 def Steering(cache, generations, input_queue, result_queue):
36 result_queue: The output task queue for this pipeline stage. The new tasks
56 result_queue.put(task)
63 result_queue.put(pipeline_process.POISONPILL)
111 result_queue.put(new_task)
116 result_queue.put(pipeline_process.POISONPILL)
steering_test.py 109 result_queue = manager.Queue()
113 args=(set(), [current_generation], input_queue, result_queue))
124 task = result_queue.get()
131 task = result_queue.get()
156 result_queue = manager.Queue()
160 args=(steering_tasks, [current_generation], input_queue, result_queue))
165 assert result_queue.get() == pipeline_process.POISONPILL
pipeline_worker_test.py 48 result_queue = manager.Queue()
54 args=(TEST_STAGE, {}, helper_queue, completed_queue, result_queue))
82 task = result_queue.get()
97 result_queue = manager.Queue()
111 result_queue)
116 output = result_queue.get()
pipeline_process.py 41 worker, result_queue):
58 result_queue: The output task queue for this pipeline stage.
65 self._result_queue = result_queue
  /external/python/futures/concurrent/futures/
process.py 108 def _process_worker(call_queue, result_queue):
109 """Evaluates calls from call_queue and places the results in result_queue.
116 result_queue: A multiprocessing.Queue of _ResultItems that will written
125 result_queue.put(None)
131 result_queue.put(_ResultItem(call_item.work_id,
134 result_queue.put(_ResultItem(call_item.work_id,
179 result_queue):
195 result_queue: A multiprocessing.Queue of _ResultItems generated by the
208 result_item = result_queue.get(block=True)
  /external/python/cpython3/Lib/concurrent/futures/
process.py 155 def _process_worker(call_queue, result_queue):
156 """Evaluates calls from call_queue and places the results in result_queue.
163 result_queue: A multiprocessing.Queue of _ResultItems that will written
172 result_queue.put(os.getpid())
178 result_queue.put(_ResultItem(call_item.work_id, exception=exc))
180 result_queue.put(_ResultItem(call_item.work_id,
225 result_queue):
241 result_queue: A multiprocessing.Queue of _ResultItems generated by the
261 reader = result_queue._reader
331 # result_queue.get()) and be able to send a sentinel again
    [all...]

Completed in 727 milliseconds