Lines Matching refs:concurrent
7 import concurrent.futures
31 """This class is *almost* compatible with concurrent.futures.Future.
44 methods in the concurrent.futures package.
320 if exc_class is concurrent.futures.CancelledError:
322 elif exc_class is concurrent.futures.TimeoutError:
324 elif exc_class is concurrent.futures.InvalidStateError:
330 def _set_concurrent_future_state(concurrent, source):
331 """Copy state from a future to a concurrent.futures.Future."""
334 concurrent.cancel()
335 if not concurrent.set_running_or_notify_cancel():
339 concurrent.set_exception(_convert_future_exc(exception))
342 concurrent.set_result(result)
348 The other Future may be a concurrent.futures.Future.
370 Compatible with both asyncio.Future and concurrent.futures.Future.
373 concurrent.futures.Future):
376 concurrent.futures.Future):
410 """Wrap concurrent.futures.Future object."""
413 assert isinstance(future, concurrent.futures.Future), \
414 f'concurrent.futures.Future is expected, got {future!r}'