Searched refs:Condition (Results 1 - 19 of 19) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/locks/
H A DCondition.java42 * {@code Condition} factors out the {@code Object} monitor
48 * and statements, a {@code Condition} replaces the use of the Object
61 * <p>A {@code Condition} instance is intrinsically bound to a lock.
62 * To obtain a {@code Condition} instance for a particular {@link Lock}
74 * {@link Condition} instances.
78 * final Condition notFull = <b>lock.newCondition(); </b>
79 * final Condition notEmpty = <b>lock.newCondition(); </b>
119 * <p>A {@code Condition} implementation can provide behavior and semantics
127 * <p>Note that {@code Condition} instances are just normal objects and can
131 * Acquiring the monitor lock of a {@code Condition} instanc
180 public interface Condition { interface
[all...]
H A DLock.java45 * {@link Condition} objects.
163 * @see Condition
340 * Returns a new {@link Condition} instance that is bound to this
345 * A call to {@link Condition#await()} will atomically release the lock
350 * <p>The exact operation of the {@link Condition} instance depends on
354 * @return A new {@link Condition} instance for this {@code Lock} instance
358 Condition newCondition();
H A DReentrantLock.java462 * Returns a {@link Condition} instance for use with this
465 * <p>The returned {@link Condition} instance supports the same
473 * <li>If this lock is not held when any of the {@link Condition}
474 * {@linkplain Condition#await() waiting} or {@linkplain
475 * Condition#signal signalling} methods are called, then an {@link
478 * <li>When the condition {@linkplain Condition#await() waiting}
498 * @return the Condition object
500 public Condition newCondition() {
692 public boolean hasWaiters(Condition condition) {
715 public int getWaitQueueLength(Condition conditio
[all...]
H A DReentrantReadWriteLock.java111 * <li><b>{@link Condition} support</b>
112 * <p>The write lock provides a {@link Condition} implementation that
114 * {@link Condition} implementation provided by
116 * This {@link Condition} can, of course, only be used with the write lock.
118 * <p>The read lock does not support a {@link Condition} and
897 public Condition newCondition() {
1142 * Returns a {@link Condition} instance for use with this
1144 * <p>The returned {@link Condition} instance supports the same
1153 * Condition} method is called then an {@link
1162 * <li>When the condition {@linkplain Condition#awai
[all...]
H A DStampedLock.java835 * support a {@link Condition}; method {@link
851 * support a {@link Condition}; method {@link
890 public Condition newCondition() {
906 public Condition newCondition() {
H A DAbstractQueuedLongSynchronizer.java1368 * Condition implementation for a {@link
1374 * and Condition users. Exported versions of this class will in
1384 public class ConditionObject implements Condition, java.io.Serializable {
1791 * waiting on this Condition.
H A DAbstractQueuedSynchronizer.java81 * can be used as a {@link Condition} implementation by subclasses
227 * // Provides a Condition
228 * Condition newCondition() { return new ConditionObject(); }
244 * public Condition newCondition() { return sync.newCondition(); }
1834 * Condition implementation for a {@link
1840 * and Condition users. Exported versions of this class will in
1848 public class ConditionObject implements Condition, java.io.Serializable {
2255 * waiting on this Condition.
/libcore/jsr166-tests/src/test/java/jsr166/
H A DReentrantLockTest.java18 import java.util.concurrent.locks.Condition;
71 public Collection<Thread> getWaitingThreads(Condition c) {
132 void assertHasNoWaiters(PublicReentrantLock lock, Condition c) {
139 void assertHasWaiters(PublicReentrantLock lock, Condition c,
156 void await(Condition c, AwaitMethod awaitMethod)
499 final Condition c = lock.newCondition();
518 final Condition c = lock.newCondition();
533 final Condition c = lock.newCondition();
553 final Condition c = lock.newCondition();
571 final Condition
[all...]
H A DReentrantReadWriteLockTest.java18 import java.util.concurrent.locks.Condition;
72 public Collection<Thread> getWaitingThreads(Condition c) {
141 void assertHasNoWaiters(PublicReentrantReadWriteLock lock, Condition c) {
148 void assertHasWaiters(PublicReentrantReadWriteLock lock, Condition c,
165 void await(Condition c, AwaitMethod awaitMethod)
884 final Condition c = lock.writeLock().newCondition();
905 final Condition c = lock.writeLock().newCondition();
919 final Condition c = lock.writeLock().newCondition();
935 final Condition c = lock.writeLock().newCondition();
956 final Condition
[all...]
H A DThreadPoolExecutorSubclassTest.java36 import java.util.concurrent.locks.Condition;
56 final Condition cond = lock.newCondition();
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DCyclicBarrier.java38 import java.util.concurrent.locks.Condition;
158 /** Condition to wait on until tripped */
159 private final Condition trip = lock.newCondition();
H A DDelayQueue.java45 import java.util.concurrent.locks.Condition;
101 * Condition signalled when a newer element becomes available
105 private final Condition available = lock.newCondition();
H A DArrayBlockingQueue.java47 import java.util.concurrent.locks.Condition;
116 /** Condition for waiting takes */
117 private final Condition notEmpty;
119 /** Condition for waiting puts */
120 private final Condition notFull;
H A DLinkedBlockingQueue.java45 import java.util.concurrent.locks.Condition;
158 private final Condition notEmpty = takeLock.newCondition();
164 private final Condition notFull = putLock.newCondition();
H A DPriorityBlockingQueue.java48 import java.util.concurrent.locks.Condition;
169 * Condition for blocking when empty.
171 private final Condition notEmpty;
H A DScheduledThreadPoolExecutor.java48 import java.util.concurrent.locks.Condition;
900 * Condition signalled when a newer task becomes available at the
903 private final Condition available = lock.newCondition();
H A DThreadPoolExecutor.java46 import java.util.concurrent.locks.Condition;
300 * private Condition unpaused = pauseLock.newCondition();
494 private final Condition termination = mainLock.newCondition();
H A DLinkedBlockingDeque.java44 import java.util.concurrent.locks.Condition;
160 /** Condition for waiting takes */
161 private final Condition notEmpty = lock.newCondition();
163 /** Condition for waiting puts */
164 private final Condition notFull = lock.newCondition();
/libcore/luni/src/test/java/libcore/java/lang/
H A DLambdaImplementationTest.java57 interface Condition<T> { interface in class:LambdaImplementationTest
62 Condition<String> c = String::isEmpty;
65 assertLambdaImplementsInterfaces(c, Condition.class);
66 assertLambdaMethodCharacteristics(c, Condition.class);
78 Method interfaceCallMethod = Condition.class.getDeclaredMethod(

Completed in 242 milliseconds