| /external/eigen/unsupported/test/ |
| D | cxx11_eventcount.cpp | 28 MaxSizeVector<EventCount::Waiter> waiters(1); in test_basic_eventcount() local
29 waiters.resize(1); in test_basic_eventcount()
30 EventCount ec(waiters); in test_basic_eventcount()
31 EventCount::Waiter& w = waiters[0]; in test_basic_eventcount()
85 MaxSizeVector<EventCount::Waiter> waiters(kThreads); in test_stress_eventcount() local
86 waiters.resize(kThreads); in test_stress_eventcount()
87 EventCount ec(waiters); in test_stress_eventcount()
108 consumers.emplace_back(new std::thread([&ec, &queues, &waiters, i]() { in test_stress_eventcount()
109 EventCount::Waiter& w = waiters[i]; in test_stress_eventcount()
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | EventCount.h | 53 EventCount(MaxSizeVector<Waiter>& waiters) : waiters_(waiters) { in EventCount() argument
54 eigen_assert(waiters.size() < (1 << kWaiterBits) - 1); in EventCount()
56 state_ = kStackMask | (kEpochMask - kEpochInc * waiters.size() * 2); in EventCount()
138 uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; in Notify() local
142 newstate = (state & kEpochMask) + (kEpochInc * waiters) + kStackMask; in Notify()
143 } else if (waiters) { in Notify()
160 if (!all && waiters) return; // unblocked pre-wait thread in Notify()
212 void Unpark(Waiter* waiters) { in Unpark() argument
214 for (Waiter* w = waiters; w; w = next) { in Unpark()
|
| /external/mesa3d/src/util/ |
| D | u_thread.h | 132 unsigned waiters; member
141 barrier->waiters = 0; in util_barrier_init()
149 assert(barrier->waiters == 0); in util_barrier_destroy()
158 assert(barrier->waiters < barrier->count); in util_barrier_wait()
159 barrier->waiters++; in util_barrier_wait()
161 if (barrier->waiters < barrier->count) { in util_barrier_wait()
168 barrier->waiters = 0; in util_barrier_wait()
|
| /external/virglrenderer/src/gallium/auxiliary/os/ |
| D | os_thread.h | 157 unsigned waiters; member
166 barrier->waiters = 0; in pipe_barrier_init()
174 assert(barrier->waiters == 0); in pipe_barrier_destroy()
183 assert(barrier->waiters < barrier->count); in pipe_barrier_wait()
184 barrier->waiters++; in pipe_barrier_wait()
186 if (barrier->waiters < barrier->count) { in pipe_barrier_wait()
193 barrier->waiters = 0; in pipe_barrier_wait()
|
| /external/libusb/libusb/os/ |
| D | threads_windows.c | 115 list_init(&cond->waiters); in usbi_cond_init()
127 if (!list_empty(&cond->waiters)) in usbi_cond_destroy()
147 list_for_each_entry(pos, &cond->waiters, list, struct usbi_cond_perthread) { in usbi_cond_broadcast()
185 list_add(&pos->list, &cond->waiters); in usbi_cond_intwait()
|
| D | threads_windows.h | 32 struct list_head waiters; member
|
| /external/python/cpython3/Lib/asyncio/ |
| D | queues.py | 61 def _wakeup_next(self, waiters): argument
63 while waiters:
64 waiter = waiters.popleft()
|
| D | base_events.py | 276 waiters = self._waiters
278 for waiter in waiters:
|
| /external/v8/src/ |
| D | futex-emulation.cc | 271 int waiters = 0; in NumWaitersForTesting() local
276 waiters++; in NumWaitersForTesting()
282 return Smi::FromInt(waiters); in NumWaitersForTesting()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 946 int waiters = guard.waiterCount++; in beginWaitingFor() local
947 if (waiters == 0) { in beginWaitingFor()
959 int waiters = --guard.waiterCount; in endWaitingFor() local
960 if (waiters == 0) { in endWaitingFor()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| D | CurrentContendedMonitorTest.java | 95 int waiters = replyObj.getNextValueAsInt(); in testCurrentContendedMonitor001() local
98 for (int i = 0; i < waiters; i++) { in testCurrentContendedMonitor001()
|
| /external/libxml2/ |
| D | threads.c | 112 unsigned int waiters; member
295 tok->waiters = 0; in xmlNewRMutex()
358 tok->waiters++; in xmlRMutexLock()
361 tok->waiters--; in xmlRMutexLock()
399 if (tok->waiters) in xmlRMutexUnlock()
|
| /external/oj-libjdwp/src/share/back/ |
| D | ObjectReferenceImpl.c | 224 (void)outStream_writeObjectRef(env, out, info.waiters[i]); in monitorInfo()
228 if (info.waiters != NULL ) in monitorInfo()
229 jvmtiDeallocate(info.waiters); in monitorInfo()
|
| /external/python/cpython3/Lib/importlib/ |
| D | _bootstrap.py | 64 self.waiters = 0
96 self.waiters += 1
112 if self.waiters:
113 self.waiters -= 1
|
| /external/python/cpython2/Lib/ |
| D | threading.py | 386 waiters = __waiters[:n]
387 if not waiters:
393 for waiter in waiters:
|
| /external/deqp/modules/egl/ |
| D | teglMultiThreadTests.cpp | 294 const deInt32 waiters = deAtomicIncrement32(&m_barrierWaiters); in barrier() local
296 if (waiters == m_threadCount) in barrier()
309 const deInt32 waiters = deAtomicDecrement32(&m_barrierWaiters); in barrier() local
311 if (waiters == 0) in barrier()
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| D | ObjectReferenceImpl.java | 531 return Arrays.asList((ThreadReference[])jdwpMonitorInfo().waiters); in waitingThreads()
|
| /external/oj-libjdwp/make/data/jdwp/ |
| D | jdwp.spec | 1583 (Repeat waiters "The number of threads that are waiting for the monitor "
|
| /external/oj-libjdwp/src/share/javavm/export/ |
| D | jvmti.h | 613 jthread* waiters; member
|
| /external/python/cpython2/Doc/library/ |
| D | threading.rst | 540 possibly be a desired state for one of the waiters. For example, the following
|
| /external/python/cpython3/Doc/library/ |
| D | threading.rst | 536 of the waiters. For example, the following code is a generic
|
| /external/python/cpython3/Misc/NEWS.d/ |
| D | 3.5.0a1.rst | 2487 mutation of the waiters queue without holding the lock. Patch by Doug
|
| /external/jline/src/src/test/resources/jline/example/ |
| D | english.gz | |
| /external/python/cpython3/Misc/ |
| D | HISTORY | 1478 caused by mutation of the waiters queue without holding the lock. Patch
|
| /external/cldr/tools/java/org/unicode/cldr/util/data/transforms/ |
| D | internal_raw_IPA.txt | 175439 waiters %33488 wˈetərz
|