Lines Matching refs:_waiters
105 self._waiters: Deque[Tuple[TaskInfo, Event]] = deque()
124 self._waiters.append(token)
129 self._waiters.remove(token)
160 if self._waiters:
161 self._owner_task, event = self._waiters.popleft()
178 return LockStatistics(self.locked(), self._owner_task, len(self._waiters))
186 self._waiters: Deque[Event] = deque()
229 event = self._waiters.popleft()
238 for event in self._waiters:
241 self._waiters.clear()
247 self._waiters.append(event)
253 self._waiters.remove(event)
266 return ConditionStatistics(len(self._waiters), self._lock.statistics())
283 self._waiters: Deque[Event] = deque()
301 self._waiters.append(event)
306 self._waiters.remove(event)
331 if self._waiters:
332 self._waiters.popleft().set()
354 return SemaphoreStatistics(len(self._waiters))