| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 60 private Thread waiter; field in class:WaitingThread
114 return this.waiter;
142 if (this.waiter != null) {
146 "\nwaiter: " + this.waiter);
152 this.waiter = Thread.currentThread();
165 this.waiter = null;
181 if (this.waiter == null) {
|
| ConnPoolByRoute.java | 684 WaitingThread waiter = iwth.next();
686 waiter.wakeup();
|
| /frameworks/base/tests/CoreTests/android/core/ |
| MonitorTest.java | 110 Waiter waiter; field in class:MonitorTest.Interrupter
112 Interrupter(String name, Waiter waiter) {
114 this.waiter = waiter;
127 waiter.spin = true;
128 // System.out.println("InterruptTest: starting waiter");
129 waiter.start();
137 /* Waiter is spinning, and its monitor should still be thin
277 Waiter waiter = new Waiter("InterruptTest Waiter"); local
[all...] |
| /external/chromium/base/ |
| waitable_event.h | 102 class Waiter {
104 // Signal the waiter to wake up.
106 // Consider the case of a Waiter which is in multiple WaitableEvent's
108 // signaled at the same time. Now, each will wake only the first waiter in
111 // to dequeue the waiter from the other wait-list in time), two auto-resets
112 // will have happened, but only one waiter has been signaled!
114 // Because of this, a Waiter may "reject" a wake by returning false. In
126 virtual ~Waiter() {}
151 bool Dequeue(Waiter* waiter, void* tag)
[all...] |
| waitable_event_posix.cc | 18 // waiter is either an async wait, in which case we have a Task and the
28 // firing a waiter and so we can store that pointer to find out which event
79 // This is a synchronous waiter. The thread is waiting on the given condition
82 class SyncWaiter : public WaitableEvent::Waiter {
259 // enqueued our waiter in them all.
299 // The locks of the WaitableEvents have been taken in order and the Waiter has
303 // None of the WaitableEvent locks are held. The Waiter has not been enqueued
310 size_t count, Waiter* waiter) {
322 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter);
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| Exchanger.java | 260 public volatile Thread waiter; field in class:Exchanger.Node
324 LockSupport.unpark(you.waiter);
450 * When a node/thread is about to block, it sets its waiter field
452 * parking, thus covering race vs fulfiller noticing that waiter
471 else if (node.waiter == null) // Set up to block next
472 node.waiter = w;
506 else if (node.waiter == null)
507 node.waiter = w;
541 LockSupport.unpark(you.waiter);
|
| SynchronousQueue.java | 209 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferStack.SNode
244 Thread w = waiter;
246 waiter = null;
358 if (m == null) // waiter is gone
381 * When a node/thread is about to block, it sets its waiter
384 * fulfiller noticing that waiter is non-null so should be
424 else if (s.waiter == null)
425 s.waiter = w; // establish waiter so can park next iter
447 s.waiter = null; // forget threa
495 volatile Thread waiter; \/\/ to control park\/unpark field in class:SynchronousQueue.TransferQueue.QNode
[all...] |
| /dalvik/tests/059-finalizer-throw/src/ |
| Main.java | 11 static Object waiter = new Object(); field in class:Main
|
| /external/dnsmasq/src/ |
| log.c | 385 struct timespec waiter; local
386 waiter.tv_sec = 0;
387 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */
388 nanosleep(&waiter, NULL);
|
| util.c | 475 struct timespec waiter; local
478 waiter.tv_sec = 0;
479 waiter.tv_nsec = 10000;
480 nanosleep(&waiter, NULL);
|
| /frameworks/base/telephony/java/com/android/internal/telephony/ |
| AdnRecordCache.java | 297 Message waiter = waiters.get(i); local
299 AsyncResult.forMessage(waiter, ar.result, ar.exception);
300 waiter.sendToTarget();
|
| /external/kernel-headers/original/linux/ |
| module.h | 326 struct task_struct *waiter; member in struct:module
416 wake_up_process(module->waiter);
|
| /external/bluetooth/glib/glib/ |
| gmain.c | 1948 GMainWaiter *waiter = context->waiters->data; local
2002 GMainWaiter waiter; local
[all...] |
| /frameworks/base/core/java/android/app/ |
| Instrumentation.java | [all...] |
