| /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...] |
