| /external/v8/src/base/platform/ |
| D | semaphore.cc | 23 Semaphore::Semaphore(int count) { in Semaphore() function in v8::base::Semaphore
31 Semaphore::~Semaphore() { in ~Semaphore()
37 void Semaphore::Signal() { in Signal()
44 void Semaphore::Wait() { in Wait()
53 bool Semaphore::WaitFor(const TimeDelta& rel_time) { in WaitFor()
75 Semaphore::Semaphore(int count) {
83 Semaphore::~Semaphore() {
89 void Semaphore::Signal() {
98 void Semaphore::Wait() {
109 bool Semaphore::WaitFor(const TimeDelta& rel_time) {
[all …]
|
| D | semaphore.h | 35 class V8_BASE_EXPORT Semaphore final {
37 explicit Semaphore(int count);
38 ~Semaphore();
70 DISALLOW_COPY_AND_ASSIGN(Semaphore);
86 static Semaphore* Create() { in Create()
87 return new Semaphore(N); in Create()
93 typedef typename LazyDynamicInstance<Semaphore, CreateSemaphoreTrait<N>,
|
| /external/deqp/framework/delibs/decpp/ |
| D | deSemaphore.hpp | 42 class Semaphore class
45 Semaphore (int initialValue, deUint32 flags = 0);
46 ~Semaphore (void);
53 Semaphore (const Semaphore& other); // Not allowed!
54 Semaphore& operator= (const Semaphore& other); // Not allowed!
70 inline void Semaphore::increment (void) throw() in increment()
85 inline void Semaphore::decrement (void) throw() in decrement()
99 inline bool Semaphore::tryDecrement (void) throw() in tryDecrement()
|
| D | deSemaphore.cpp | 37 Semaphore::Semaphore (int initialValue, deUint32 flags) in Semaphore() function in de::Semaphore
48 Semaphore::~Semaphore (void) in ~Semaphore()
|
| D | deThreadSafeRingBuffer.hpp | 63 Semaphore m_fill;
64 Semaphore m_empty;
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | StripedTest.java | 37 import java.util.concurrent.Semaphore;
72 private static final Supplier<Semaphore> SEMAPHORE_SUPPLER = new Supplier<Semaphore>() {
73 @Override public Semaphore get() {
74 return new Semaphore(1, false);
88 .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER)) in weakImplementations()
89 .add(new Striped.SmallLazyStriped<Semaphore>(64, SEMAPHORE_SUPPLER)) in weakImplementations()
90 .add(new Striped.LargeLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER)) in weakImplementations()
91 .add(new Striped.LargeLazyStriped<Semaphore>(64, SEMAPHORE_SUPPLER)) in weakImplementations()
|
| /external/sl4a/ScriptingLayerForAndroid/src/org/connectbot/service/ |
| D | PromptHelper.java | 20 import java.util.concurrent.Semaphore;
35 private Semaphore promptToken;
36 private Semaphore promptResponse;
48 promptToken = new Semaphore(1); in PromptHelper()
51 promptResponse = new Semaphore(0); in PromptHelper()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Striped.java | 38 import java.util.concurrent.Semaphore;
235 public static Striped<Semaphore> semaphore(int stripes, final int permits) {
236 return new CompactStriped<Semaphore>(stripes, new Supplier<Semaphore>() {
237 @Override public Semaphore get() {
251 public static Striped<Semaphore> lazyWeakSemaphore(int stripes, final int permits) {
252 return lazy(stripes, new Supplier<Semaphore>() {
253 @Override public Semaphore get() {
254 return new Semaphore(permits, false);
477 private static class PaddedSemaphore extends Semaphore {
|
| D | Uninterruptibles.java | 29 import java.util.concurrent.Semaphore;
296 Semaphore semaphore, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly()
307 Semaphore semaphore, int permits, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly()
|
| /external/jmdns/src/javax/jmdns/impl/ |
| D | DNSStatefulObject.java | 7 import java.util.concurrent.Semaphore;
37 private final ConcurrentMap<Thread, Semaphore> _semaphores;
46 _semaphores = new ConcurrentHashMap<Thread, Semaphore>(50); in DNSStatefulObjectSemaphore()
57 Semaphore semaphore = _semaphores.get(thread); in waitForEvent()
59 semaphore = new Semaphore(1, true); in waitForEvent()
75 Collection<Semaphore> semaphores = _semaphores.values(); in signalEvent()
76 for (Semaphore semaphore : semaphores) { in signalEvent()
|
| /external/replicaisland/src/com/replica/replicaisland/ |
| D | RenderingWatchDog.java | 18 import java.util.concurrent.Semaphore;
34 private Semaphore mSemaphore;
50 mSemaphore = new Semaphore(0); in start()
|
| /external/volley/src/test/java/com/android/volley/mock/ |
| D | WaitableQueue.java | 24 import java.util.concurrent.Semaphore;
32 private final Semaphore mStopEvent = new Semaphore(0);
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | synchronize.py | 108 class Semaphore(SemLock): class
127 class BoundedSemaphore(Semaphore):
199 self._sleeping_count = Semaphore(0)
200 self._woken_count = Semaphore(0)
201 self._wait_semaphore = Semaphore(0)
303 self._flag = Semaphore(0)
|
| D | __init__.py | 192 def Semaphore(value=1): function
196 from multiprocessing.synchronize import Semaphore
197 return Semaphore(value)
|
| /external/guava/guava-tests/test/com/google/common/base/ |
| D | FinalizableReferenceQueueClassLoaderUnloadingTest.java | 33 import java.util.concurrent.Semaphore;
165 public static final Semaphore finalized = new Semaphore(0);
230 Semaphore finalizeCount = (Semaphore) sepFrqUserFinalizedF.get(null); in doTestUnloadableInStaticFieldIfClosed()
|
| /external/deqp/external/vulkancts/modules/vulkan/ |
| D | vktBuildPrograms.cpp | 136 SyncTask (de::Semaphore* enterBarrier, de::Semaphore* inBarrier, de::Semaphore* leaveBarrier) in SyncTask()
156 de::Semaphore* m_enterBarrier;
157 de::Semaphore* m_inBarrier;
158 de::Semaphore* m_leaveBarrier;
163 de::Semaphore enterBarrier (0); in waitForComplete()
164 de::Semaphore inBarrier (0); in waitForComplete()
165 de::Semaphore leaveBarrier (0); in waitForComplete()
|
| /external/v8/src/heap/ |
| D | page-parallel-job.h | 43 base::Semaphore* semaphore) in PageParallelJob()
139 base::Semaphore* on_finish, typename JobTraits::PerTaskData data) in Task()
178 base::Semaphore* on_finish_;
188 base::Semaphore* pending_tasks_;
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | synchronize.py | 124 class Semaphore(SemLock): class
143 class BoundedSemaphore(Semaphore):
215 self._sleeping_count = ctx.Semaphore(0)
216 self._woken_count = ctx.Semaphore(0)
217 self._wait_semaphore = ctx.Semaphore(0)
337 self._flag = ctx.Semaphore(0)
|
| D | context.py | 79 def Semaphore(self, value=1): member in BaseContext
81 from .synchronize import Semaphore
82 return Semaphore(value, ctx=self.get_context())
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_locks.py | 710 sem = asyncio.Semaphore(loop=loop)
713 sem = asyncio.Semaphore(loop=self.loop)
718 sem = asyncio.Semaphore()
722 sem = asyncio.Semaphore(0, loop=self.loop)
726 sem = asyncio.Semaphore(loop=self.loop)
744 sem = asyncio.Semaphore(loop=self.loop)
762 self.assertRaises(ValueError, asyncio.Semaphore, -1)
765 sem = asyncio.Semaphore(3, loop=self.loop)
830 sem = asyncio.Semaphore(loop=self.loop)
842 sem = asyncio.Semaphore(value=0, loop=self.loop)
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-sync.rst | 15 * :class:`Semaphore`
20 :class:`~threading.Condition`, :class:`~threading.Semaphore`,
243 Semaphore section in Semaphores
246 .. class:: Semaphore(value=1, \*, loop=None)
248 A Semaphore implementation.
290 A bounded semaphore implementation. Inherit from :class:`Semaphore`.
292 This raises :exc:`ValueError` in :meth:`~Semaphore.release` if it would
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidRenderActivity.hpp | 64 de::Semaphore* semaphore;
99 Message (MessageType type_, de::Semaphore* semaphore) in Message()
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| D | IOHandler.java | 38 import java.util.concurrent.Semaphore;
62 private Semaphore ioSemaphore = new Semaphore(1);
|
| /external/ltp/testcases/open_posix_testsuite/stress/semaphores/ |
| D | coverage.txt | 1 This file defines the coverage for Semaphore stress tests.
|
| /external/v8/src/ |
| D | d8.h | 137 base::Semaphore next_semaphore_;
138 base::Semaphore done_semaphore_;
274 base::Semaphore in_semaphore_;
275 base::Semaphore out_semaphore_;
|