Lines Matching refs:futures
17 # Possible future states (for internal use by the futures package).
42 # Logger for internal use by the futures package.
43 LOGGER = logging.getLogger("concurrent.futures")
144 def __init__(self, futures):
145 self.futures = sorted(futures, key=id)
148 for future in self.futures:
152 for future in self.futures:
179 Iterate on the list *fs*, yielding finished futures one by one in
200 """An iterator over the given futures that yields each as it completes.
240 '%d (of %d) futures unfinished' % (
256 # Remove waiter from unfinished futures
264 """Wait for the futures in the given sequence to complete.
279 ALL_COMPLETED - Return when all futures finish or are cancelled.
283 futures that completed (is finished or cancelled) before the wait
285 futures. Duplicate futures given to *fs* are removed and will be
610 # Yield must be hidden in closure so that the futures are submitted
635 futures have finished executing and the resources used by the
638 futures. Futures that are completed or running will not be