/development/simulator/app/ |
Semaphore.h | 4 // Inter-process semaphore. 19 * Platform-independent semaphore class. 21 * Each object holds a single semaphore. 24 * semaphore (following POSIX semantics). See the comments in shmem.h. 26 class Semaphore { 28 Semaphore(void); 29 virtual ~Semaphore(void); 32 * Create a new semaphore, with the specified initial value. The 38 * Attach to an existing semaphore. 43 * Acquire or release the semaphore [all...] |
Semaphore.cpp | 6 #include "Semaphore.h" 9 # include <semaphore.h> 32 Semaphore::Semaphore(void) 36 Semaphore::~Semaphore(void) 39 bool Semaphore::create(int key, int initialValue, bool deleteExisting) 44 bool Semaphore::attach(int key) 49 void Semaphore::acquire(void) 52 void Semaphore::release(void [all...] |
Shmem.h | 13 #include "Semaphore.h" 21 * For convenience, a semaphore is associated with each segment. 85 Semaphore mSem; // uses the same value for "key"
|
Android.mk | 31 Semaphore.cpp \
|
/libcore/luni/src/test/java/tests/api/java/util/concurrent/ |
SemaphoreTest.java | 25 static class PublicSemaphore extends Semaphore { 39 final Semaphore lock; 40 InterruptibleLockRunnable(Semaphore l) { lock = l; } 54 final Semaphore lock; 55 InterruptedLockRunnable(Semaphore l) { lock = l; } 67 Semaphore s = new Semaphore(permits, fair); 79 Semaphore s = new Semaphore(permits); 89 Semaphore s = new Semaphore(2, false) [all...] |
ThreadLocalTest.java | 12 import java.util.concurrent.Semaphore;
|
/libcore/luni/src/main/java/java/util/concurrent/ |
Semaphore.java | 14 * A counting semaphore. Conceptually, a semaphore maintains a set of 18 * However, no actual permit objects are used; the {@code Semaphore} just 23 * a class that uses a semaphore to control access to a pool of items: 27 * private final Semaphore available = new Semaphore(MAX_AVAILABLE, true); 71 * the semaphore, guaranteeing that an item is available for use. When 73 * pool and a permit is returned to the semaphore, allowing another 76 * from being returned to the pool. The semaphore encapsulates the 81 * <p>A semaphore initialized to one, and which is used such that i [all...] |
/external/v8/src/ |
debug-agent.h | 76 Semaphore* terminate_now_; // Semaphore to signal termination. 77 Semaphore* listening_;
|
platform.h | 117 class Semaphore; 226 // Factory method for creating platform dependent Semaphore. 227 // Please use delete to reclaim the storage for the returned Semaphore. 228 static Semaphore* CreateSemaphore(int count); 438 // Semaphore 440 // A semaphore object is a synchronization object that maintains a count. The 441 // count is decremented each time a thread completes a wait for the semaphore 442 // object and incremented each time a thread signals the semaphore. When the 443 // count reaches zero, threads waiting for the semaphore blocks until the 446 class Semaphore { [all...] |
d8-debug.h | 86 // the list is guarded by a mutex and a semaphore signals new items in the 89 i::Semaphore* event_available_;
|
platform-nullos.cc | 390 class NullSemaphore : public Semaphore { 412 Semaphore* OS::CreateSemaphore(int count) {
|
platform-macos.cc | 40 #include <semaphore.h> 43 #include <mach/semaphore.h> 496 class MacOSSemaphore : public Semaphore { 506 // The MacOS mach semaphore documentation claims it does not have spurious 528 Semaphore* OS::CreateSemaphore(int count) {
|
/frameworks/base/tests/CoreTests/android/core/ |
SocketTest.java | 30 import java.util.concurrent.Semaphore; 117 final Semaphore semThreadEnd = new Semaphore(0);
|
/external/v8/test/cctest/ |
test-lock.cc | 45 Semaphore* sem = OS::CreateSemaphore(0); 47 // Semaphore not signalled - timeout. 55 // Semaphore signalled - no timeout.
|
cctest.h | 115 v8::internal::Semaphore* gate_; 119 static v8::internal::Semaphore* all_tests_done_;
|
test-sockets.cc | 36 Semaphore* listening_; // Signalled when the server socket is in listen mode.
|
/frameworks/base/graphics/java/android/renderscript/ |
RSSurfaceView.java | 21 import java.util.concurrent.Semaphore;
|
/frameworks/base/libs/rs/java/Film/src/com/android/film/ |
FilmView.java | 21 import java.util.concurrent.Semaphore;
|
/frameworks/base/libs/rs/java/Fountain/src/com/android/fountain/ |
FountainView.java | 21 import java.util.concurrent.Semaphore;
|
/cts/tools/host/src/com/android/cts/ |
DeviceManager.java | 27 import java.util.concurrent.Semaphore; 45 private Semaphore mSemaphore = new Semaphore(0); 231 // increment the counter semaphore to unblock threads waiting for devices 322 // Reset the device counter semaphore. We will wait below until at least one device 359 deviceFound = false; // go wait for next semaphore permit
|
/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 ");
|
SIPTransaction.java | 47 import java.util.concurrent.Semaphore; 131 private Semaphore semaphore; field in class:SIPTransaction 332 this.semaphore = new Semaphore(1,true); [all...] |
/frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/stress/ |
MediaRecorderStressTest.java | 26 import java.util.concurrent.Semaphore; 73 final Semaphore sem = new Semaphore(0); 112 final Semaphore sem = new Semaphore(0);
|
/libcore/luni/src/test/java/libcore/java/lang/ |
OldThreadTest.java | 22 import java.util.concurrent.Semaphore; 309 final Semaphore sem = new Semaphore(0);
|
/external/nist-sip/java/gov/nist/javax/sip/ |
SipStackImpl.java | 54 import java.util.concurrent.Semaphore; 463 // Stack semaphore (global lock). 464 private Semaphore stackSemaphore = new Semaphore(1); [all...] |