Home
last modified time | relevance | path

Searched refs:Condition (Results 1 – 25 of 32) sorted by relevance

12

/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/locks/
DReentrantLock.java72 public java.util.concurrent.locks.Condition newCondition() { in newCondition()
112 public boolean hasWaiters(java.util.concurrent.locks.Condition condition) { in hasWaiters()
116 public int getWaitQueueLength(java.util.concurrent.locks.Condition condition) { in getWaitQueueLength()
121 java.util.concurrent.locks.Condition condition) { in getWaitingThreads()
/libcore/jsr166-tests/src/test/java/jsr166/
DReentrantLockTest.java18 import java.util.concurrent.locks.Condition;
71 public Collection<Thread> getWaitingThreads(Condition c) { in getWaitingThreads()
132 void assertHasNoWaiters(PublicReentrantLock lock, Condition c) { in assertHasNoWaiters()
139 void assertHasWaiters(PublicReentrantLock lock, Condition c, in assertHasWaiters()
156 void await(Condition c, AwaitMethod awaitMethod) in await()
499 final Condition c = lock.newCondition(); in testAwait_IMSE()
518 final Condition c = lock.newCondition();
533 final Condition c = lock.newCondition();
553 final Condition c = lock.newCondition();
571 final Condition c = lock.newCondition(); in testAwaitUntil_Timeout()
[all …]
DReentrantReadWriteLockTest.java18 import java.util.concurrent.locks.Condition;
72 public Collection<Thread> getWaitingThreads(Condition c) { in getWaitingThreads()
141 void assertHasNoWaiters(PublicReentrantReadWriteLock lock, Condition c) { in assertHasNoWaiters()
148 void assertHasWaiters(PublicReentrantReadWriteLock lock, Condition c, in assertHasWaiters()
165 void await(Condition c, AwaitMethod awaitMethod) in await()
884 final Condition c = lock.writeLock().newCondition(); in testAwait_IMSE()
905 final Condition c = lock.writeLock().newCondition();
919 final Condition c = lock.writeLock().newCondition();
935 final Condition c = lock.writeLock().newCondition();
956 final Condition c = lock.writeLock().newCondition();
[all …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DReentrantLockTest.java44 import java.util.concurrent.locks.Condition;
94 public Collection<Thread> getWaitingThreads(Condition c) { in getWaitingThreads()
155 void assertHasNoWaiters(PublicReentrantLock lock, Condition c) { in assertHasNoWaiters()
162 void assertHasWaiters(PublicReentrantLock lock, Condition c, in assertHasWaiters()
179 void await(Condition c, AwaitMethod awaitMethod) in await()
522 final Condition c = lock.newCondition(); in testAwait_IMSE()
541 final Condition c = lock.newCondition();
555 final Condition c = lock.newCondition();
575 final Condition c = lock.newCondition();
593 final Condition c = lock.newCondition(); in testAwaitUntil_Timeout()
[all …]
DReentrantReadWriteLockTest.java44 import java.util.concurrent.locks.Condition;
95 public Collection<Thread> getWaitingThreads(Condition c) { in getWaitingThreads()
164 void assertHasNoWaiters(PublicReentrantReadWriteLock lock, Condition c) { in assertHasNoWaiters()
171 void assertHasWaiters(PublicReentrantReadWriteLock lock, Condition c, in assertHasWaiters()
188 void await(Condition c, AwaitMethod awaitMethod) in await()
907 final Condition c = lock.writeLock().newCondition(); in testAwait_IMSE()
928 final Condition c = lock.writeLock().newCondition();
942 final Condition c = lock.writeLock().newCondition();
956 final Condition c = lock.writeLock().newCondition();
976 final Condition c = lock.writeLock().newCondition();
[all …]
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DReentrantLock.java536 public Condition newCondition() { in newCondition()
728 public boolean hasWaiters(Condition condition) { in hasWaiters()
751 public int getWaitQueueLength(Condition condition) { in getWaitQueueLength()
776 protected Collection<Thread> getWaitingThreads(Condition condition) { in getWaitingThreads()
DReentrantReadWriteLock.java906 public Condition newCondition() { in newCondition()
1193 public Condition newCondition() { in newCondition()
1428 public boolean hasWaiters(Condition condition) { in hasWaiters()
1451 public int getWaitQueueLength(Condition condition) { in getWaitQueueLength()
1476 protected Collection<Thread> getWaitingThreads(Condition condition) { in getWaitingThreads()
DLock.java358 Condition newCondition(); in newCondition()
DCondition.java180 public interface Condition { interface
DStampedLock.java1049 public Condition newCondition() { in newCondition()
1065 public Condition newCondition() { in newCondition()
/libcore/ojluni/src/main/java/java/util/concurrent/
DCyclicBarrier.java38 import java.util.concurrent.locks.Condition;
161 private final Condition trip = lock.newCondition();
DDelayQueue.java46 import java.util.concurrent.locks.Condition;
106 private final Condition available = lock.newCondition();
DLinkedBlockingQueue.java46 import java.util.concurrent.locks.Condition;
160 private final Condition notEmpty = takeLock.newCondition();
167 private final Condition notFull = putLock.newCondition();
DArrayBlockingQueue.java47 import java.util.concurrent.locks.Condition;
125 private final Condition notEmpty;
129 private final Condition notFull;
DScheduledThreadPoolExecutor.java49 import java.util.concurrent.locks.Condition;
959 private final Condition available = lock.newCondition();
DLinkedBlockingDeque.java45 import java.util.concurrent.locks.Condition;
163 private final Condition notEmpty = lock.newCondition();
167 private final Condition notFull = lock.newCondition();
DPriorityBlockingQueue.java51 import java.util.concurrent.locks.Condition;
170 private final Condition notEmpty = lock.newCondition();
DThreadPoolExecutor.java46 import java.util.concurrent.locks.Condition;
487 private final Condition termination = mainLock.newCondition();
DForkJoinPool.java55 import java.util.concurrent.locks.Condition;
1420 Condition termination; // lazily constructed
2343 ReentrantLock lock; Condition cond; // signal when no workers
3278 ReentrantLock lock; Condition cond;
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DReentrantReadWriteLockTest.java24 import java.util.concurrent.locks.Condition;
90 final Condition condition = lock.readLock().newCondition(); in testReadLockCondition()
/libcore/luni/src/test/java/libcore/java/lang/
DLambdaImplementationTest.java57 interface Condition<T> { interface in LambdaImplementationTest
62 Condition<String> c = String::isEmpty; in testInstanceMethodReferenceLambda()
65 assertLambdaImplementsInterfaces(c, Condition.class); in testInstanceMethodReferenceLambda()
66 assertLambdaMethodCharacteristics(c, Condition.class); in testInstanceMethodReferenceLambda()
78 Method interfaceCallMethod = Condition.class.getDeclaredMethod( in testInstanceMethodReferenceLambda()
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DLinkedBlockingQueue.java191 private final java.util.concurrent.locks.Condition notEmpty;
197 private final java.util.concurrent.locks.Condition notFull;
DLinkedBlockingDeque.java299 private final java.util.concurrent.locks.Condition notEmpty;
305 private final java.util.concurrent.locks.Condition notFull;
DPriorityBlockingQueue.java225 private final java.util.concurrent.locks.Condition notEmpty;
DThreadPoolExecutor.java379 private final java.util.concurrent.locks.Condition termination;

12