| /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);
|
