diff --git a/satella/coding/concurrent/sync.py b/satella/coding/concurrent/sync.py index c1bd66765140f0569e5ad1aa9e4b65e61ab2f721..5c4f5aaa321d096f4ed7b639c35fe0638a884989 100644 --- a/satella/coding/concurrent/sync.py +++ b/satella/coding/concurrent/sync.py @@ -23,11 +23,10 @@ def _max_wait_atm_n(measurement, max_wait, atm_n): while measurement() < max_wait: try: atm_n.wait_until_equal(0, 1) - break + return except WouldWaitMore: continue - else: - raise WouldWaitMore('timeout exceeded') + raise WouldWaitMore('timeout exceeded') def sync_threadpool(tpe: tp.Union[ExecutorWrapper, ThreadPoolExecutor],