| /libcore/luni/src/main/java/java/util/concurrent/ |
| Semaphore.java | 14 * permits. Each {@link #acquire} blocks if necessary until a permit is
82 * available, or zero permits available. When used in this way, the
91 * guarantees about the order in which threads acquire permits. In
97 * #acquire() acquire} methods are selected to obtain permits in the order in
105 * honor the fairness setting, but will take any permits that are
116 * permits at a time. Beware of the increased risk of indefinite
135 * to represent permits. Subclassed into fair and nonfair
141 Sync(int permits) {
142 setState(permits);
196 NonfairSync(int permits) {
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| RateLimiter.java | 29 * A rate limiter. Conceptually, a rate limiter distributes permits at a
31 * available, and then takes it. Once acquired, permits need not be released.
39 * <p>A {@code RateLimiter} is defined primarily by the rate at which permits
40 * are issued. Absent additional configuration, permits will be distributed at a
41 * fixed rate, defined in terms of permits per second. Permits will be distributed
42 * smoothly, with the delay between individual permits being adjusted to ensure
46 * period during which time the permits issued each second steadily increases until
52 * final RateLimiter rateLimiter = RateLimiter.create(2.0); // rate is "2 permits per second"
63 * a rate of 5000 permits per second
[all...] |
| Striped.java | 230 * with the specified number of permits.
233 * @param permits the number of permits in each semaphore
236 public static Striped<Semaphore> semaphore(int stripes, final int permits) {
239 return new PaddedSemaphore(permits);
246 * with the specified number of permits.
249 * @param permits the number of permits in each semaphore
252 public static Striped<Semaphore> lazyWeakSemaphore(int stripes, final int permits) {
255 return new Semaphore(permits, false)
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| SemaphoreTest.java | 35 PublicSemaphore(int permits) { super(permits); }
36 PublicSemaphore(int permits, boolean fair) { super(permits, fair); }
106 void acquire(Semaphore s, int permits) throws InterruptedException {
107 s.acquire(permits);
116 void acquire(Semaphore s, int permits) {
117 s.acquireUninterruptibly(permits);
126 void acquire(Semaphore s, int permits) {
127 assertTrue(s.tryAcquire(permits));
[all...] |
| /external/clang/test/Sema/ |
| predef.c | 15 // rdar://6097892 - GCC permits this insanity.
|
| /packages/apps/UnifiedEmail/src/com/android/mail/ui/ |
| FragmentLauncher.java | 23 * Interface that permits elements to display a Fragment.
|
| FolderSelector.java | 23 * Interface that permits elements to implement selecting a folder.
|
| /libcore/luni/src/main/java/java/nio/channels/ |
| InterruptibleChannel.java | 25 * A channel that can be asynchronously closed permits that a thread blocked on
30 * A channel that is interruptible permits a thread blocked on an I/O operation
|
| ScatteringByteChannel.java | 49 * if the channel has not been opened in a mode that permits
85 * if the channel has not been opened in a mode that permits
|
| /external/jmonkeyengine/engine/src/core/checkers/quals/ |
| DefaultQualifiers.java | 13 * This annotation permits specifying multiple default qualifiers for more
|
| /frameworks/av/include/media/nbaio/ |
| LibsndfileSource.h | 30 // If 'loop' is true and it permits seeking, then we'll act as an infinite source
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| RateLimiterTest.java | 101 limiter.acquire(1); // R0.00, concluding a burst of 5 permits
154 // make sure the areas (times) remain the same, while permits are different
172 ticker.sleepMillis(3000); // fill up 3 permits
173 limiter.acquire(5); // we had 3 ready, thus we borrow 2 permits
177 "R0.00", // 10 permits grabbed
294 * amount of permits in a cool state, where X = rate * timeToCoolDown, and we have
323 private long measureTotalTimeMillis(RateLimiter rateLimiter, int permits, Random random) {
325 while (permits > 0) {
326 int nextPermitsToAcquire = Math.max(1, random.nextInt(permits));
327 permits -= nextPermitsToAcquire
[all...] |
| /packages/apps/Camera2/src/com/android/camera/util/ |
| ConcurrentSharedRingBuffer.java | 133 * A Semaphore that allows to reduce permits to negative values.
136 public NegativePermitsSemaphore(int permits) {
137 super(permits);
141 * Reduces the number of permits by <code>permits</code>.
143 * This method can only be called when number of available permits is
147 public void reducePermits(int permits) {
151 super.reducePermits(permits);
192 // Start with -1 permits to pin elements since we must always have at
511 // Release the capacity permits
[all...] |
| /external/nist-sip/java/gov/nist/javax/sip/ |
| package.html | 14 <li> Message Logging features - permits the application to log messages in
|
| /external/ppp/pppd/plugins/radius/ |
| pppd-radius.8 | 20 The RADIUS plugin for pppd permits pppd to perform PAP, CHAP, MS-CHAP and
|
| /external/xmp_toolkit/XMPCore/src/com/adobe/xmp/ |
| XMPError.java | 6 // NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the terms
|
| XMPException.java | 6 // NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the terms
|
| XMPVersionInfo.java | 6 // NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the terms
|
| /external/xmp_toolkit/XMPCore/src/com/adobe/xmp/properties/ |
| XMPProperty.java | 6 // NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the terms
|
| /external/compiler-rt/test/cfi/ |
| multiple-inheritance.cpp | 22 // permits calls via virtual tables for the correct base class.
|
| /external/libxml2/test/schemas/ |
| changelog093_1.xsd | 50 <cc:permits rdf:resource="http://web.resource.org/cc/Reproduction" />
51 <cc:permits rdf:resource="http://web.resource.org/cc/Distribution" />
54 <cc:permits rdf:resource="http://web.resource.org/cc/DerivativeWorks" />
67 type which explicitly permits content from foreign namespaces.
|
| /external/llvm/utils/fpcmp/ |
| fpcmp.cpp | 1 //===- fpcmp.cpp - A fuzzy "cmp" that permits floating point noise --------===//
|
| /external/mesa3d/src/glsl/ |
| ir_print_visitor.h | 81 * GLSL IR permits multiple ir_variables to share the same name. This works
|
| /external/openssh/ |
| ssh.h | 29 * Current value permits 16kbit RSA and RSA1 keys and 8kbit DSA keys, with
|
| /external/xmp_toolkit/XMPCore/src/com/adobe/xmp/impl/ |
| CountOutputStream.java | 6 // NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the terms
|
