Lines Matching refs:_waiters
36 self._waiters = collections.deque() # Futures.
44 self._waiters = collections.deque(
45 w for w in self._waiters if not w.done())
114 if self._waiters:
115 result += ' waiters[%s]' % len(self._waiters)
125 self._waiters.append(waiter)
140 while n and self._waiters:
141 waiter = self._waiters.popleft()
151 self.notify(len(self._waiters))
195 self._waiters = set()
213 for fut in self._waiters:
234 self._waiters.add(fut)
235 fut.add_done_callback(lambda fut: self._waiters.remove(fut))
371 if self._waiters:
372 extra = '{0},waiters:{1}'.format(extra, len(self._waiters))
378 while self._waiters:
379 waiter = self._waiters.popleft()
403 self._waiters.append(waiter)