Lines Matching refs:future
23 | | | future | | | | 4, result | | |
38 - reads _ResultItems from "Result Q", updates the future stored in the
140 def __init__(self, future, fn, args, kwargs):
141 self.future = future
162 """Safe Queue set exception to the future object linked to a job"""
181 work_item.future.set_exception(e)
391 if work_item.future.set_running_or_notify_cancel():
446 # Received a _ResultItem so mark the future as completed.
451 work_item.future.set_exception(result_item.exception)
453 work_item.future.set_result(result_item.result)
482 "terminated abruptly while the future was "
490 work_item.future.set_exception(bpe)
515 if not work_item.future.cancel():
611 while a future was in the running state.