| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| JSR166TestCase.java | 937 public void await(Semaphore semaphore) {
939 assertTrue(semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS));
[all...] |
| /external/ims/rcs/rcsservice/src/com/android/service/ims/ |
| RcsStackAdaptor.java | 32 import java.util.concurrent.Semaphore;
|
| /external/ims/rcs/rcsservice/src/com/android/service/ims/presence/ |
| PresenceSubscriber.java | 35 import java.util.concurrent.Semaphore;
|
| /external/v8/src/debug/ |
| debug.h | 647 base::Semaphore command_received_; // Signaled for each command received.
|
| /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/tycho-bundles-external/0.20.0/eclipse/plugins/ |
| org.eclipse.core.jobs_3.5.300.v20130429-1813.jar | |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_threading.py | 619 # variable instead of a semaphore, while we know that the Python-level
731 semtype = staticmethod(threading.Semaphore)
|
| test_multiprocessing.py | 160 # Return the value of a semaphore
669 sem = self.Semaphore(2)
688 sem = self.Semaphore(0)
730 sleeping = self.Semaphore(0)
731 woken = self.Semaphore(0)
773 sleeping = self.Semaphore(0)
774 woken = self.Semaphore(0)
856 # instead of None. API Shear with the semaphore backed mp.Event
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_threading.py | 619 # variable instead of a semaphore, while we know that the Python-level
731 semtype = staticmethod(threading.Semaphore)
|
| test_multiprocessing.py | 160 # Return the value of a semaphore
669 sem = self.Semaphore(2)
688 sem = self.Semaphore(0)
730 sleeping = self.Semaphore(0)
731 woken = self.Semaphore(0)
773 sleeping = self.Semaphore(0)
774 woken = self.Semaphore(0)
856 # instead of None. API Shear with the semaphore backed mp.Event
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_threading.py | 619 # variable instead of a semaphore, while we know that the Python-level
731 semtype = staticmethod(threading.Semaphore)
|
| test_multiprocessing.py | 160 # Return the value of a semaphore
669 sem = self.Semaphore(2)
688 sem = self.Semaphore(0)
730 sleeping = self.Semaphore(0)
731 woken = self.Semaphore(0)
773 sleeping = self.Semaphore(0)
774 woken = self.Semaphore(0)
856 # instead of None. API Shear with the semaphore backed mp.Event
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_threading.py | 619 # variable instead of a semaphore, while we know that the Python-level
731 semtype = staticmethod(threading.Semaphore)
|
| test_multiprocessing.py | 160 # Return the value of a semaphore
669 sem = self.Semaphore(2)
688 sem = self.Semaphore(0)
730 sleeping = self.Semaphore(0)
731 woken = self.Semaphore(0)
773 sleeping = self.Semaphore(0)
774 woken = self.Semaphore(0)
856 # instead of None. API Shear with the semaphore backed mp.Event
[all...] |
| /prebuilts/tools/common/m2/repository/org/eclipse/tycho/tycho-bundles-external/0.18.1/eclipse/plugins/ |
| org.eclipse.core.jobs_3.5.300.v20130429-1813.jar | |
| /system/core/libmemunreachable/ |
| MemUnreachable.cpp | 37 #include "Semaphore.h"
272 Semaphore continue_parent_sem;
|
| /external/deqp/modules/egl/ |
| teglRenderTests.cpp | 818 typedef de::SharedPtr<de::Semaphore> SemaphoreSp;
937 *sem = SemaphoreSp(new de::Semaphore(0));
989 // Create and launch threads (actual rendering starts once first semaphore is signaled).
[all...] |
| teglMultiThreadTests.cpp | 167 de::Semaphore m_barrierSemaphore1;
168 de::Semaphore m_barrierSemaphore2;
[all...] |
| /prebuilts/tools/common/m2/repository/backport-util-concurrent/backport-util-concurrent/3.1/ |
| backport-util-concurrent-3.1.jar | |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/camera/its/ |
| ItsService.java | 89 import java.util.concurrent.Semaphore;
152 private Semaphore mSocketQueueQuota = null;
337 mSocketQueueQuota = new Semaphore(quota, true);
[all...] |
| /cts/tests/tests/webkit/src/android/webkit/cts/ |
| WebViewTest.java | 93 import java.util.concurrent.Semaphore;
[all...] |
| /external/deqp/external/vulkancts/framework/vulkan/ |
| vkNullDriverImpl.inl | 31 VK_NULL_RETURN((*pSemaphore = allocateNonDispHandle<Semaphore, VkSemaphore>(device, pCreateInfo, pAllocator)));
200 VKAPI_ATTR void VKAPI_CALL destroySemaphore (VkDevice device, VkSemaphore semaphore, const VkAllocationCallbacks* pAllocator)
203 freeNonDispHandle<Semaphore, VkSemaphore>(semaphore, pAllocator);
[all...] |
| /external/icu/tools/srcgen/currysrc/libs/ |
| org.eclipse.core.jobs_3.7.0.v20150330-2103.jar | |
| /external/v8/src/heap/ |
| mark-compact.cc | 446 SweeperTask(Sweeper* sweeper, base::Semaphore* pending_sweeper_tasks,
471 base::Semaphore* pending_sweeper_tasks_;
[all...] |
| /external/v8/test/cctest/ |
| test-lockers.cc | 167 v8::base::Semaphore semaphore_;
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/ |
| threading.py | 31 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Thread',
411 def Semaphore(*args, **kwargs):
412 """A factory function that returns a new semaphore.
430 # After Tim Peters' semaphore class, but not quite the same (no maximum)
434 raise ValueError("semaphore initial value must be >= 0")
440 """Acquire a semaphore, decrementing the internal counter by one.
479 """Release a semaphore, incrementing the internal counter by one.
497 """A factory function that returns a new bounded semaphore.
499 A bounded semaphore checks to make sure its current value doesn't exceed its
503 If the semaphore is released too many times it's a sign of a bug. If no
[all...] |
