| /libcore/luni/src/test/java/libcore/java/lang/ |
| D | OldAndroidMonitorTest.java | 145 final Waiter waiter = new Waiter(lock, cdl); in testInterrupt() local
147 waiter.start(); in testInterrupt()
159 waiter.interrupt(); in testInterrupt()
164 waiter.join(); in testInterrupt()
170 assertTrue(waiter.wasInterrupted()); in testInterrupt()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | AbstractQueuedSynchronizer.java | 457 Thread waiter; // visibly nonnull when enqueued field in AbstractQueuedSynchronizer.Node
586 LockSupport.unpark(node.waiter); in enqueue()
611 LockSupport.unpark(s.waiter); in signalNext()
621 LockSupport.unpark(s.waiter); in signalNextIfShared()
682 node.waiter = null; in acquire()
697 node.waiter = current; in acquire()
773 node.waiter = null; in cancelAcquire()
1145 (first = s.waiter) == null || in getFirstQueuedThread()
1149 if ((w = p.waiter) != null) in getFirstQueuedThread()
1169 if (p.waiter == thread) in isQueued()
[all …]
|
| D | AbstractQueuedLongSynchronizer.java | 92 Thread waiter; // visibly nonnull when enqueued field in AbstractQueuedLongSynchronizer.Node
221 LockSupport.unpark(node.waiter); in enqueue()
246 LockSupport.unpark(s.waiter); in signalNext()
256 LockSupport.unpark(s.waiter); in signalNextIfShared()
317 node.waiter = null; in acquire()
332 node.waiter = current; in acquire()
407 node.waiter = null; in cancelAcquire()
779 (first = s.waiter) == null || in getFirstQueuedThread()
783 if ((w = p.waiter) != null) in getFirstQueuedThread()
803 if (p.waiter == thread) in isQueued()
[all …]
|
| D | StampedLock.java | 352 Thread waiter; // visibly nonnull when enqueued field in StampedLock.Node
1163 LockSupport.unpark(s.waiter); in signalNext()
1174 LockSupport.unpark(c.waiter); in signalCowaiters()
1224 node.waiter = null; in acquireWrite()
1244 if (node.waiter == null) in acquireWrite()
1245 node.waiter = Thread.currentThread(); in acquireWrite()
1307 else if (node.waiter == null) in acquireRead()
1308 node.waiter = Thread.currentThread(); in acquireRead()
1328 node.waiter = null; in acquireRead()
1361 node.waiter = null; in acquireRead()
[all …]
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SynchronousQueue.java | 234 volatile Thread waiter; // to control park/unpark field in SynchronousQueue.TransferStack.SNode
262 if ((w = waiter) != null) in tryMatch()
392 s.waiter = w; // enable signal in transfer()
508 volatile Thread waiter; // to control park/unpark field in SynchronousQueue.TransferQueue.QNode
693 s.waiter = w; in transfer()
717 Thread waiter; in transfer() local
723 if ((waiter = m.waiter) != null) in transfer()
724 LockSupport.unpark(waiter); in transfer()
|
| D | SubmissionPublisher.java | 1062 Thread waiter; // blocked producer thread field in SubmissionPublisher.BufferedSubscription
1438 if ((w = waiter) != null) in signalWaiter()
1488 else if (waiter == null) in block()
1489 waiter = Thread.currentThread(); in block()
1497 waiter = null; in block()
|
| D | LinkedTransferQueue.java | 393 volatile Thread waiter; // null when not waiting for a match field in LinkedTransferQueue.Node
448 LockSupport.unpark(waiter); in tryMatch()
660 s.waiter = w; // enable unpark in awaitMatch()
1101 s.waiter = null; // disable signals in unsplice()
|
| D | ConcurrentHashMap.java | 2781 volatile Thread waiter; field in ConcurrentHashMap.TreeBin
2876 waiter = null; in contendedLock()
2883 waiter = Thread.currentThread(); in contendedLock()
2915 (READER|WAITER) && (w = waiter) != null) in find()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ScheduledExecutorSubclassTest.java | 725 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
733 p.execute(waiter); in testShutdownNow()
1258 final Callable<String> waiter = new CheckedCallable<String>() {
1267 tasks.add(waiter);
|
| D | ScheduledExecutorTest.java | 674 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
682 p.execute(waiter); in testShutdownNow()
1208 final Callable<String> waiter = new CheckedCallable<String>() {
1217 tasks.add(waiter);
|
| D | ThreadPoolExecutorTest.java | 658 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
666 p.execute(waiter); in testShutdownNow()
1889 final Callable<String> waiter = new CheckedCallable<String>() {
1901 tasks.add(waiter);
|
| D | ThreadPoolExecutorSubclassTest.java | 773 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
781 p.execute(waiter); in testShutdownNow()
1882 final Callable<String> waiter = new CheckedCallable<String>() {
1894 tasks.add(waiter);
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ScheduledExecutorSubclassTest.java | 749 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
757 p.execute(waiter); in testShutdownNow()
1285 final Callable<String> waiter = new CheckedCallable<String>() {
1294 tasks.add(waiter);
|
| D | ScheduledExecutorTest.java | 697 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
705 p.execute(waiter); in testShutdownNow()
1234 final Callable<String> waiter = new CheckedCallable<String>() {
1243 tasks.add(waiter);
|
| D | ThreadPoolExecutorTest.java | 680 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
688 p.execute(waiter); in testShutdownNow()
1906 final Callable<String> waiter = new CheckedCallable<String>() {
1918 tasks.add(waiter);
|
| D | ThreadPoolExecutorSubclassTest.java | 795 Runnable waiter = new CheckedRunnable() { public void realRun() { in testShutdownNow() local
803 p.execute(waiter); in testShutdownNow()
1904 final Callable<String> waiter = new CheckedCallable<String>() {
1916 tasks.add(waiter);
|