Lines Matching refs:future
6 immediately or at a given time in the future.
266 # Cancel the future.
569 future = self.create_future()
570 thread = threading.Thread(target=self._do_shutdown, args=(future,))
573 await future
577 def _do_shutdown(self, future):
581 self.call_soon_threadsafe(future.set_result, None)
584 self.call_soon_threadsafe(future.set_exception, ex)
617 def run_until_complete(self, future):
631 new_task = not futures.isfuture(future)
632 future = tasks.ensure_future(future, loop=self)
634 # An exception is raised if the future didn't complete, so there
636 future._log_destroy_pending = False
638 future.add_done_callback(_run_until_complete_cb)
642 if new_task and future.done() and not future.cancelled():
646 future.exception()
649 future.remove_done_callback(_run_until_complete_cb)
650 if not future.done():
653 return future.result()
1733 (e.g. a handle or future or task) was created, if any.
1780 - 'future' (optional): Future instance;
1789 New keys maybe introduced in the future.