| /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/swiftshader/src/Vulkan/ |
| D | VkSemaphore.hpp | 23 class Semaphore : public Object<Semaphore, VkSemaphore> class
26 Semaphore(const VkSemaphoreCreateInfo* pCreateInfo, void* mem) {} in Semaphore() function in vk::Semaphore
28 ~Semaphore() = delete;
55 static inline Semaphore* Cast(VkSemaphore object) in Cast()
57 return reinterpret_cast<Semaphore*>(object); in Cast()
|
| /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/v8/src/heap/ |
| D | item-parallel-job.h | 22 class Semaphore; variable
108 base::Semaphore* on_finish, std::vector<Item*>* items,
118 base::Semaphore* on_finish_ = nullptr;
125 base::Semaphore* pending_tasks);
146 base::Semaphore* pending_tasks_;
|
| D | item-parallel-job.cc | 23 base::Semaphore* on_finish, std::vector<Item*>* items, size_t start_index, in SetupInternal()
49 base::Semaphore* pending_tasks) in ItemParallelJob()
|
| /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/python/cpython3/Doc/library/ |
| D | asyncio-sync.rst | 25 * :class:`Semaphore`
248 Semaphore chapter
251 .. class:: Semaphore(value=1, \*, loop=None)
253 A Semaphore object. Not thread-safe.
265 The preferred way to use a Semaphore is an :keyword:`async with`
268 sem = asyncio.Semaphore(10)
276 sem = asyncio.Semaphore(10)
302 Unlike :class:`BoundedSemaphore`, :class:`Semaphore` allows
313 Bounded Semaphore is a version of :class:`Semaphore` that raises
314 a :exc:`ValueError` in :meth:`~Semaphore.release` if it
|
| /external/opencensus-java/contrib/agent/src/integration-test/java/io/opencensus/contrib/agent/instrumentation/ |
| D | ExecutorInstrumentationIT.java | 26 import java.util.concurrent.Semaphore;
66 final Semaphore tested = new Semaphore(0); in execute()
165 final Semaphore tested = new Semaphore(0); in currentContextExecutor()
|
| /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/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadClient.java | 43 import java.util.concurrent.Semaphore;
327 final Semaphore maxOutstanding = new Semaphore(config.getOutstandingRpcsPerChannel());
371 final Semaphore maxOutstanding = new Semaphore(config.getOutstandingRpcsPerChannel());
447 final Semaphore maxOutstanding = new Semaphore(config.getOutstandingRpcsPerChannel());
494 final Semaphore maxOutstanding = new Semaphore(config.getOutstandingRpcsPerChannel());
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | synchronize.py | 123 class Semaphore(SemLock): class
142 class BoundedSemaphore(Semaphore):
214 self._sleeping_count = ctx.Semaphore(0)
215 self._woken_count = ctx.Semaphore(0)
216 self._wait_semaphore = ctx.Semaphore(0)
325 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/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/python/cpython3/Lib/test/test_asyncio/ |
| D | test_locks.py | 74 asyncio.Semaphore(loop=loop),
832 sem = asyncio.Semaphore(loop=loop)
835 sem = asyncio.Semaphore(loop=self.loop)
840 sem = asyncio.Semaphore()
844 sem = asyncio.Semaphore(0, loop=self.loop)
848 sem = asyncio.Semaphore(loop=self.loop)
866 sem = asyncio.Semaphore(loop=self.loop)
885 self.assertRaises(ValueError, asyncio.Semaphore, -1)
888 sem = asyncio.Semaphore(3, loop=self.loop)
949 sem = asyncio.Semaphore(loop=self.loop)
[all …]
|
| /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);
|