Lines Matching refs:result
23 | | | future | | | | 4, result | | |
112 # - the result queue reader
147 def __init__(self, work_id, exception=None, result=None, exit_pid=None):
150 self.result = result
208 def _sendback_result(result_queue, work_id, result=None, exception=None,
210 """Safely send back the given result or exception"""
212 result_queue.put(_ResultItem(work_id, result=result,
262 _sendback_result(result_queue, call_item.work_id, result=r,
402 # Wait for a result to be ready in the result_queue while checking
453 work_item.future.set_result(result_item.result)
700 # as it could result in a deadlock if a worker process dies with the
752 'deadlock in the child processes could result.')
809 TimeoutError: If the entire result iterator could not be generated