Lines Matching refs:concurrent
7 import concurrent.futures
317 if exc_class is concurrent.futures.CancelledError:
319 elif exc_class is concurrent.futures.TimeoutError:
321 elif exc_class is concurrent.futures.InvalidStateError:
327 def _set_concurrent_future_state(concurrent, source): argument
331 concurrent.cancel()
332 if not concurrent.set_running_or_notify_cancel():
336 concurrent.set_exception(_convert_future_exc(exception))
339 concurrent.set_result(result)
370 concurrent.futures.Future):
373 concurrent.futures.Future):
408 assert isinstance(future, concurrent.futures.Future), \