/external/chromium_org/android_webview/javatests/src/org/chromium/android_webview/test/ |
ArchiveTest.java | 18 import java.util.concurrent.Semaphore; 55 final Semaphore s = new Semaphore(0);
|
/external/chromium_org/v8/test/cctest/ |
test-threads.cc | 129 v8::base::Semaphore* semaphore) 134 semaphore_(semaphore) {} 153 v8::base::Semaphore* semaphore_; 161 v8::base::Semaphore semaphore(0); 165 new ThreadIdValidationThread(prev, &refs, i, &semaphore); 172 semaphore.Wait();
|
test-circular-queue.cc | 109 v8::base::Semaphore* finished) 131 v8::base::Semaphore* finished_; 144 v8::base::Semaphore semaphore(0); 146 ProducerThread producer1(&scq, kRecordsPerChunk, 1, &semaphore); 147 ProducerThread producer2(&scq, kRecordsPerChunk, 10, &semaphore); 148 ProducerThread producer3(&scq, kRecordsPerChunk, 20, &semaphore); 152 semaphore.Wait(); 164 semaphore.Wait(); 176 semaphore.Wait() [all...] |
/frameworks/base/tests/CoreTests/android/core/ |
SocketTest.java | 30 import java.util.concurrent.Semaphore; 117 final Semaphore semThreadEnd = new Semaphore(0);
|
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
__init__.py | 50 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition', 192 def Semaphore(value=1): 194 Returns a semaphore object 196 from multiprocessing.synchronize import Semaphore 197 return Semaphore(value) 201 Returns a bounded semaphore object
|
synchronize.py | 36 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition', 'Event' 65 RECURSIVE_MUTEX, SEMAPHORE = range(2) 105 # Semaphore 108 class Semaphore(SemLock): 111 SemLock.__init__(self, SEMAPHORE, value, SEM_VALUE_MAX) 121 return '<Semaphore(value=%s)>' % value 124 # Bounded semaphore 127 class BoundedSemaphore(Semaphore): 130 SemLock.__init__(self, SEMAPHORE, value, value) 147 SemLock.__init__(self, SEMAPHORE, 1, 1 [all...] |
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
__init__.py | 50 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition', 192 def Semaphore(value=1): 194 Returns a semaphore object 196 from multiprocessing.synchronize import Semaphore 197 return Semaphore(value) 201 Returns a bounded semaphore object
|
synchronize.py | 36 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition', 'Event' 65 RECURSIVE_MUTEX, SEMAPHORE = range(2) 105 # Semaphore 108 class Semaphore(SemLock): 111 SemLock.__init__(self, SEMAPHORE, value, SEM_VALUE_MAX) 121 return '<Semaphore(value=%s)>' % value 124 # Bounded semaphore 127 class BoundedSemaphore(Semaphore): 130 SemLock.__init__(self, SEMAPHORE, value, value) 147 SemLock.__init__(self, SEMAPHORE, 1, 1 [all...] |
/cts/suite/audio_quality/lib/include/audio/ |
RemoteAudio.h | 31 #include "Semaphore.h" 78 // this is just semaphore wait without any addition 94 Semaphore mInitWait; 134 Semaphore mClientWait;
|
/external/chromium_org/v8/src/ |
optimizing-compiler-thread.h | 112 base::Semaphore stop_semaphore_; 113 base::Semaphore input_queue_semaphore_;
|
/external/deqp/framework/platform/android/ |
tcuAndroidRenderActivity.hpp | 52 MESSAGE_SYNC, //!< Main thread requests sync. Data argument is de::Semaphore* that needs to be incremented. 64 de::Semaphore* semaphore; member in union:tcu::Android::Message::__anon24387 99 Message (MessageType type_, de::Semaphore* semaphore) 103 DE_ASSERT(semaphore); 104 payload.semaphore = semaphore;
|
/hardware/ti/omap4-aah/camera/inc/OMXCameraAdapter/ |
OMXCameraAdapter.h | 492 OMX_IN Utils::Semaphore &semaphore); [all...] |
/hardware/ti/omap4xxx/camera/inc/OMXCameraAdapter/ |
OMXCameraAdapter.h | 440 OMX_IN Semaphore &semaphore); [all...] |
/external/deqp/executor/ |
xeCallQueue.hpp | 117 de::Semaphore m_callSem;
|
/frameworks/base/tests/RenderScriptTests/ModelViewer/src/com/android/modelviewer/ |
SceneGraphView.java | 21 import java.util.concurrent.Semaphore;
|
/frameworks/base/tests/RenderScriptTests/PerfTest/src/com/android/perftest/ |
RsBenchView.java | 21 import java.util.concurrent.Semaphore;
|
/frameworks/rs/java/tests/RsTest_11/src/com/android/rs/test/ |
RSTestView.java | 21 import java.util.concurrent.Semaphore;
|
/frameworks/rs/java/tests/RsTest_14/src/com/android/rs/test/ |
RSTestView.java | 21 import java.util.concurrent.Semaphore;
|
/frameworks/rs/java/tests/RsTest_16/src/com/android/rs/test/ |
RSTestView.java | 21 import java.util.concurrent.Semaphore;
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
ThreadLocalTest.java | 12 import java.util.concurrent.Semaphore;
|
/external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/signin/ |
OAuth2TokenService.java | 24 import java.util.concurrent.Semaphore; 183 final Semaphore semaphore = new Semaphore(0); local 190 semaphore.release(); 194 if (semaphore.tryAcquire(timeout, unit)) {
|
/external/nist-sip/java/gov/nist/javax/sip/stack/ |
IOHandler.java | 38 import java.util.concurrent.Semaphore; 62 private Semaphore ioSemaphore = new Semaphore(1); 183 "Could not acquire IO Semaphore after 10 seconds -- giving up ");
|
/frameworks/base/packages/DocumentsUI/src/com/android/documentsui/ |
RecentLoader.java | 52 import java.util.concurrent.Semaphore; 79 private final Semaphore mQueryPermits; 164 mQueryPermits = new Semaphore(
|
/frameworks/volley/tests/src/com/android/volley/ |
RequestQueueTest.java | 34 import java.util.concurrent.Semaphore; 138 private Semaphore mSemaphore; 143 mSemaphore = new Semaphore(-expectedRequests);
|
/cts/tests/tests/database/src/android/database/sqlite/cts/ |
SQLiteQueryBuilderTest.java | 33 import java.util.concurrent.Semaphore; 334 final Semaphore barrier1 = new Semaphore(0); 335 final Semaphore barrier2 = new Semaphore(0);
|