Lines Matching refs:waiter
157 waiter = _AsCompletedWaiter()
159 waiter = _FirstCompletedWaiter()
165 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=True)
167 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=False)
172 f._waiters.append(waiter)
174 return waiter
177 def _yield_finished_futures(fs, waiter, ref_collect):
181 Before yielding a future, *waiter* is removed from its waiters
193 f._waiters.remove(waiter)
227 waiter = _create_and_install_waiters(fs, _AS_COMPLETED)
230 yield from _yield_finished_futures(finished, waiter,
243 waiter.event.wait(wait_timeout)
245 with waiter.lock:
246 finished = waiter.finished_futures
247 waiter.finished_futures = []
248 waiter.event.clear()
252 yield from _yield_finished_futures(finished, waiter,
256 # Remove waiter from unfinished futures
259 f._waiters.remove(waiter)
303 waiter = _create_and_install_waiters(fs, return_when)
305 waiter.event.wait(timeout)
308 f._waiters.remove(waiter)
310 done.update(waiter.finished_futures)
523 for waiter in self._waiters:
524 waiter.add_cancelled(self)
547 for waiter in self._waiters:
548 waiter.add_result(self)
562 for waiter in self._waiters:
563 waiter.add_exception(self)