OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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