Searched refs:waiter (Results 1 - 8 of 8) sorted by relevance

/libcore/luni/src/test/java/libcore/java/lang/
H A DOldAndroidMonitorTest.java145 final Waiter waiter = new Waiter(lock, cdl);
147 waiter.start();
149 // Wait for the "waiter" to start and acquire |lock| for the first time.
156 // Interrupt |waiter| after we acquire |lock|. This ensures that |waiter| is
159 waiter.interrupt();
162 // Wait for the waiter to complete.
164 waiter.join();
170 assertTrue(waiter.wasInterrupted());
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DSynchronousQueue.java237 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferStack.SNode
264 Thread w = waiter;
266 waiter = null;
392 if (m == null) // waiter is gone
415 * When a node/thread is about to block, it sets its waiter
418 * fulfiller noticing that waiter is non-null so should be
456 else if (s.waiter == null)
457 s.waiter = w; // establish waiter so can park next iter
479 s.waiter
539 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferQueue.QNode
[all...]
H A DLinkedTransferQueue.java420 * is apparently the first waiter in the queue. See above for
455 volatile Thread waiter; // null until waiting field in class:LinkedTransferQueue.Node
485 * Sets item to self and waiter to null, to avoid garbage
489 * mechanics that extract items. Similarly, clearing waiter
532 LockSupport.unpark(waiter);
552 (Node.class.getDeclaredField("waiter"));
624 LockSupport.unpark(p.waiter);
721 else if (s.waiter == null) {
722 s.waiter = w; // request unpark then recheck
745 if (pred.waiter
[all...]
H A DConcurrentHashMap.java471 * waiter, we use a simple scheme using a single "waiter" field to
2781 volatile Thread waiter; field in class:ConcurrentHashMap.TreeBin
2876 waiter = null;
2883 waiter = Thread.currentThread();
2915 (READER|WAITER) && (w = waiter) != null)
/libcore/jsr166-tests/src/test/java/jsr166/
H A DScheduledExecutorSubclassTest.java725 Runnable waiter = new CheckedRunnable() { public void realRun() {
733 p.execute(waiter);
1258 final Callable<String> waiter = new CheckedCallable<String>() {
1267 tasks.add(waiter);
H A DScheduledExecutorTest.java674 Runnable waiter = new CheckedRunnable() { public void realRun() {
682 p.execute(waiter);
1208 final Callable<String> waiter = new CheckedCallable<String>() {
1217 tasks.add(waiter);
H A DThreadPoolExecutorSubclassTest.java773 Runnable waiter = new CheckedRunnable() { public void realRun() {
781 p.execute(waiter);
1882 final Callable<String> waiter = new CheckedCallable<String>() {
1894 tasks.add(waiter);
H A DThreadPoolExecutorTest.java658 Runnable waiter = new CheckedRunnable() { public void realRun() {
666 p.execute(waiter);
1889 final Callable<String> waiter = new CheckedCallable<String>() {
1901 tasks.add(waiter);

Completed in 194 milliseconds