Home
last modified time | relevance | path

Searched refs:_waiters (Results 1 – 25 of 245) sorted by relevance

12345678910

/dports/lang/python310/Python-3.10.1/Lib/asyncio/
H A Dlocks.py78 self._waiters = None
84 if self._waiters:
103 if self._waiters is None:
106 self._waiters.append(fut)
143 if not self._waiters:
174 if self._waiters:
211 self._waiters.append(fut)
245 if self._waiters:
315 for fut in self._waiters:
357 if self._waiters:
[all …]
/dports/lang/python311/Python-3.11.0a3/Lib/asyncio/
H A Dlocks.py78 self._waiters = None
84 if self._waiters:
103 if self._waiters is None:
106 self._waiters.append(fut)
143 if not self._waiters:
174 if self._waiters:
211 self._waiters.append(fut)
245 if self._waiters:
315 for fut in self._waiters:
357 if self._waiters:
[all …]
/dports/devel/py-asyncio/asyncio-3.4.3/asyncio/
H A Dlocks.py107 if self._waiters:
127 self._waiters.append(fut)
133 self._waiters.remove(fut)
149 for fut in self._waiters:
202 if self._waiters:
218 for fut in self._waiters:
240 self._waiters.append(fut)
280 if self._waiters:
342 for fut in self._waiters:
400 if self._waiters:
[all …]
/dports/graphics/panomatic/panomatic-0.9.4/zthread/src/
H A DRecursiveMutexImpl.cxx62 if(_waiters.size() > 0) { in ~RecursiveMutexImpl()
99 _waiters.push_back(&m); in acquire()
116 List::iterator i = std::find(_waiters.begin(), _waiters.end(), &m); in acquire()
117 if(i != _waiters.end()) in acquire()
118 _waiters.erase(i); in acquire()
169 _waiters.push_back(&m); in tryAcquire()
193 List::iterator i = std::find(_waiters.begin(), _waiters.end(), &m); in tryAcquire()
194 if(i != _waiters.end()) in tryAcquire()
195 _waiters.erase(i); in tryAcquire()
247 for(List::iterator i = _waiters.begin(); i != _waiters.end();) { in release()
[all …]
H A DConditionImpl.h47 List _waiters;
89 if(_waiters.size() != 0) {
113 for(typename List::iterator i = _waiters.begin(); i != _waiters.end();) {
139 if(_waiters.empty())
166 for(typename List::iterator i = _waiters.begin(); i != _waiters.end();) {
188 if(_waiters.empty())
228 _waiters.insert(self);
247 typename List::iterator i = std::find(_waiters.begin(), _waiters.end(), self);
249 _waiters.erase(i);
335 typename List::iterator i = std::find(_waiters.begin(), _waiters.end(), self);
[all …]
H A DMutexImpl.h69 List _waiters; variable
114 if(_waiters.size() > 0) { in ~MutexImpl()
164 _waiters.insert(self); in acquire()
184 typename List::iterator i = std::find(_waiters.begin(), _waiters.end(), self); in acquire()
185 if(i != _waiters.end()) in acquire()
186 _waiters.erase(i); in acquire()
247 _waiters.insert(self); in tryAcquire()
276 typename List::iterator i = std::find(_waiters.begin(), _waiters.end(), self); in tryAcquire()
278 _waiters.erase(i); in tryAcquire()
335 for(typename List::iterator i = _waiters.begin(); i != _waiters.end();) { in release()
[all …]
H A DSemaphoreImpl.h51 List _waiters; variable
103 if(_waiters.size() > 0) { in ~SemaphoreImpl()
153 _waiters.insert(self); in acquire()
170 typename List::iterator i = std::find(_waiters.begin(), _waiters.end(), self); in acquire()
171 if(i != _waiters.end()) in acquire()
172 _waiters.erase(i); in acquire()
243 typename List::iterator i = std::find(_waiters.begin(), _waiters.end(), self); in tryAcquire()
244 if(i != _waiters.end()) in tryAcquire()
245 _waiters.erase(i); in tryAcquire()
296 for(typename List::iterator i = _waiters.begin(); i != _waiters.end();) { in release()
[all …]
/dports/lang/python39/Python-3.9.9/Lib/asyncio/
H A Dlocks.py78 self._waiters = None
91 if self._waiters:
110 if self._waiters is None:
113 self._waiters.append(fut)
150 if not self._waiters:
187 if self._waiters:
224 self._waiters.append(fut)
267 if self._waiters:
337 for fut in self._waiters:
385 if self._waiters:
[all …]
/dports/devel/py-trollius/trollius-2.2/trollius/
H A Dlocks.py138 if self._waiters:
158 self._waiters.append(fut)
164 self._waiters.remove(fut)
180 for fut in self._waiters:
208 if self._waiters:
224 for fut in self._waiters:
246 self._waiters.append(fut)
286 if self._waiters:
359 for fut in self._waiters:
405 if self._waiters:
[all …]
/dports/databases/py-gdbm/Python-3.8.12/Lib/asyncio/
H A Dlocks.py161 self._waiters = None
174 if self._waiters:
193 if self._waiters is None:
196 self._waiters.append(fut)
233 if not self._waiters:
270 if self._waiters:
307 self._waiters.append(fut)
350 if self._waiters:
420 for fut in self._waiters:
468 if self._waiters:
[all …]
/dports/databases/py-sqlite3/Python-3.8.12/Lib/asyncio/
H A Dlocks.py161 self._waiters = None
174 if self._waiters:
193 if self._waiters is None:
196 self._waiters.append(fut)
233 if not self._waiters:
270 if self._waiters:
307 self._waiters.append(fut)
350 if self._waiters:
420 for fut in self._waiters:
468 if self._waiters:
[all …]
/dports/lang/python-tools/Python-3.8.12/Lib/asyncio/
H A Dlocks.py161 self._waiters = None
174 if self._waiters:
193 if self._waiters is None:
196 self._waiters.append(fut)
233 if not self._waiters:
270 if self._waiters:
307 self._waiters.append(fut)
350 if self._waiters:
420 for fut in self._waiters:
468 if self._waiters:
[all …]
/dports/x11-toolkits/py-tkinter/Python-3.8.12/Lib/asyncio/
H A Dlocks.py161 self._waiters = None
174 if self._waiters:
193 if self._waiters is None:
196 self._waiters.append(fut)
233 if not self._waiters:
270 if self._waiters:
307 self._waiters.append(fut)
350 if self._waiters:
420 for fut in self._waiters:
468 if self._waiters:
[all …]
/dports/lang/python38/Python-3.8.12/Lib/asyncio/
H A Dlocks.py161 self._waiters = None
174 if self._waiters:
193 if self._waiters is None:
196 self._waiters.append(fut)
233 if not self._waiters:
270 if self._waiters:
307 self._waiters.append(fut)
350 if self._waiters:
420 for fut in self._waiters:
468 if self._waiters:
[all …]
/dports/lang/python37/Python-3.7.12/Lib/asyncio/
H A Dlocks.py166 if self._waiters:
185 self._waiters.append(fut)
254 if self._waiters:
270 for fut in self._waiters:
291 self._waiters.append(fut)
296 self._waiters.remove(fut)
331 if self._waiters:
352 self._waiters.append(fut)
401 for fut in self._waiters:
446 if self._waiters:
[all …]
/dports/www/py-tornado5/tornado-5.1.1/tornado/
H A Dlocks.py44 self._waiters = collections.deque(
114 if self._waiters:
125 self._waiters.append(waiter)
140 while n and self._waiters:
151 self.notify(len(self._waiters))
195 self._waiters = set()
213 for fut in self._waiters:
234 self._waiters.add(fut)
371 if self._waiters:
378 while self._waiters:
[all …]
/dports/www/py-tornado/tornado-6.1/tornado/
H A Dlocks.py50 self._waiters = collections.deque(w for w in self._waiters if not w.done())
119 if self._waiters:
132 self._waiters.append(waiter)
148 while n and self._waiters:
149 waiter = self._waiters.popleft()
159 self.notify(len(self._waiters))
224 for fut in self._waiters:
247 self._waiters.add(fut)
394 if self._waiters:
401 while self._waiters:
[all …]
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/producer/
H A Dbuffer.py29 self._waiters = collections.deque()
63 self._waiters.append(more_memory)
76 self._waiters.remove(more_memory)
83 removed = self._waiters.popleft()
88 if self._free and self._waiters:
89 self._waiters[0].notify()
109 if self._waiters:
110 self._waiters[0].notify()
115 return len(self._waiters)
/dports/www/py-tornado4/tornado-4.5.3/tornado/
H A Dlocks.py35 self._waiters = collections.deque() # Futures.
43 self._waiters = collections.deque(
112 if self._waiters:
123 self._waiters.append(waiter)
137 while n and self._waiters:
138 waiter = self._waiters.popleft()
148 self.notify(len(self._waiters))
356 if self._waiters:
363 while self._waiters:
364 waiter = self._waiters.popleft()
[all …]
/dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/
H A Dlocks.py36 self._waiters = collections.deque() # Futures.
44 self._waiters = collections.deque(
113 if self._waiters:
124 self._waiters.append(waiter)
138 while n and self._waiters:
139 waiter = self._waiters.popleft()
149 self.notify(len(self._waiters))
357 if self._waiters:
364 while self._waiters:
365 waiter = self._waiters.popleft()
[all …]
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/util/
H A D_notifier.py28 self._waiters = []
32 self._waiters.append(d)
36 if self._waiters:
37 waiters, self._waiters = self._waiters, []
42 return bool(self._waiters)
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/schedulers/
H A Dtriggerable.py33 self._waiters = {}
72 self._waiters[bsid] = (resultsDeferred, brids)
94 if self._waiters:
96 for d, brids in self._waiters.values():
98 self._waiters = {}
105 if self._waiters and not self._buildset_complete_consumer:
110 elif not self._waiters and self._buildset_complete_consumer:
115 if msg['bsid'] not in self._waiters:
119 d, brids = self._waiters.pop(msg['bsid'])
/dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/taskflow-2.5.0/include/taskflow/core/
H A Dnotifier.hpp84 explicit Notifier(size_t N) : _waiters{N} { in Notifier()
85 assert(_waiters.size() < (1 << kWaiterBits) - 1);
87 _state = kStackMask | (kEpochMask - kEpochInc * _waiters.size() * 2);
124 newstate = (newstate & ~kStackMask) | (w - &_waiters[0]); in commit_wait()
179 Waiter* w = &_waiters[state & kStackMask]; in notify()
182 if (wnext != nullptr) next = wnext - &_waiters[0]; in notify()
193 Waiter* w = &_waiters[state & kStackMask]; in notify()
203 if(n >= _waiters.size()) { in notify_n()
214 return _waiters.size(); in size()
235 std::vector<Waiter> _waiters; member in tf::Notifier
[all …]
/dports/devel/py-rapidfuzz/rapidfuzz-1.8.0/3rd-party/taskflow/taskflow/core/
H A Dnotifier.hpp84 explicit Notifier(size_t N) : _waiters{N} { in Notifier()
85 assert(_waiters.size() < (1 << kWaiterBits) - 1);
87 _state = kStackMask | (kEpochMask - kEpochInc * _waiters.size() * 2);
124 newstate = (newstate & ~kStackMask) | (w - &_waiters[0]); in commit_wait()
179 Waiter* w = &_waiters[state & kStackMask]; in notify()
182 if (wnext != nullptr) next = wnext - &_waiters[0]; in notify()
193 Waiter* w = &_waiters[state & kStackMask]; in notify()
203 if(n >= _waiters.size()) { in notify_n()
214 return _waiters.size(); in size()
235 std::vector<Waiter> _waiters; member in tf::Notifier
[all …]
/dports/devel/py-anyio/anyio-3.4.0/src/anyio/_core/
H A D_synchronization.py124 self._waiters.append(token)
160 if self._waiters:
186 self._waiters: Deque[Event] = deque()
238 for event in self._waiters:
241 self._waiters.clear()
247 self._waiters.append(event)
253 self._waiters.remove(event)
283 self._waiters: Deque[Event] = deque()
301 self._waiters.append(event)
331 if self._waiters:
[all …]

12345678910