Lines Matching refs:result_queue
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 is
142 result_queue.put(task)
