Lines Matching full:concurrent

7 import concurrent.futures
30     """This class is *almost* compatible with concurrent.futures.Future.
43       methods in the concurrent.futures package.
293     if exc_class is concurrent.futures.CancelledError:
295     elif exc_class is concurrent.futures.TimeoutError:
297     elif exc_class is concurrent.futures.InvalidStateError:
303 def _set_concurrent_future_state(concurrent, source):  argument
304     """Copy state from a future to a concurrent.futures.Future."""
307         concurrent.cancel()
308     if not concurrent.set_running_or_notify_cancel():
312         concurrent.set_exception(_convert_future_exc(exception))
315         concurrent.set_result(result)
321     The other Future may be a concurrent.futures.Future.
343     Compatible with both asyncio.Future and concurrent.futures.Future.
346                                                concurrent.futures.Future):
349                                                     concurrent.futures.Future):
381     """Wrap concurrent.futures.Future object."""
384     assert isinstance(future, concurrent.futures.Future), \
385         f'concurrent.futures.Future is expected, got {future!r}'