/dports/lang/python310/Python-3.10.1/Lib/asyncio/ |
H A D | locks.py | 78 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 D | locks.py | 78 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 D | locks.py | 107 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 D | RecursiveMutexImpl.cxx | 62 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 D | ConditionImpl.h | 47 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 D | MutexImpl.h | 69 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 D | SemaphoreImpl.h | 51 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 D | locks.py | 78 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 D | locks.py | 138 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 D | locks.py | 161 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 D | locks.py | 161 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 D | locks.py | 161 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 D | locks.py | 161 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 D | locks.py | 161 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 D | locks.py | 166 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 D | locks.py | 44 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 D | locks.py | 50 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 D | buffer.py | 29 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 D | locks.py | 35 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 D | locks.py | 36 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.py | 28 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 D | triggerable.py | 33 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 D | notifier.hpp | 84 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 D | notifier.hpp | 84 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.py | 124 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 …]
|