HomeSort by relevance Sort by last modified time
    Searched refs:Waiter (Results 1 - 9 of 9) sorted by null

  /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
EventCount.h 22 // EventCount::Waiter& w = waiters[my_index];
45 // operations it is guaranteed than either waiter will see predicate change
47 // the waiter, or both. But it can't happen that both threads don't see each
51 class Waiter;
53 EventCount(MaxSizeVector<Waiter>& waiters) : waiters_(waiters) {
66 // and call either CancelWait or CommitWait passing the same Waiter object.
67 void Prewait(Waiter* w) {
73 void CommitWait(Waiter* w) {
74 w->state = Waiter::kNotSignaled;
75 // Modification epoch of this waiter
    [all...]
SimpleThreadPool.h 64 Waiter* w = waiters_.back();
91 Waiter w;
124 struct Waiter {
139 MaxSizeVector<Waiter*> waiters_; // Stack of waiting threads.
NonBlockingThreadPool.h 128 MaxSizeVector<EventCount::Waiter> waiters_;
141 EventCount::Waiter* waiter = &waiters_[thread_id]; local
160 if (!WaitForWork(waiter, &t)) {
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) {
199 ec_.Prewait(waiter);
203 ec_.CancelWait(waiter);
212 ec_.CancelWait(waiter);
232 ec_.CommitWait(waiter);
    [all...]
  /external/libchrome/base/synchronization/
waitable_event.h 135 class Waiter {
137 // Signal the waiter to wake up.
139 // Consider the case of a Waiter which is in multiple WaitableEvent's
141 // signaled at the same time. Now, each will wake only the first waiter in
144 // to dequeue the waiter from the other wait-list in time), two auto-resets
145 // will have happened, but only one waiter has been signaled!
147 // Because of this, a Waiter may "reject" a wake by returning false. In
159 virtual ~Waiter() = default;
250 bool Dequeue(Waiter* waiter, void* tag)
    [all...]
waitable_event_posix.cc 26 // waiter is either an async wait, in which case we have a Task and the
36 // firing a waiter and so we can store that pointer to find out which event
86 // This is a synchronous waiter. The thread is waiting on the given condition
89 class SyncWaiter : public WaitableEvent::Waiter {
275 // enqueued our waiter in them all.
320 // The locks of the WaitableEvents have been taken in order and the Waiter has
324 // None of the WaitableEvent locks are held. The Waiter has not been enqueued
331 Waiter* waiter) {
343 // No events signaled. All locks acquired. Enqueue the Waiter on all of the
    [all...]
waitable_event_watcher_posix.cc 58 // This is an asynchronous waiter which posts a task to a SequencedTaskRunner
61 class AsyncWaiter : public WaitableEvent::Waiter {
179 // We have no kernel. This means that we never enqueued a Waiter on an
198 // fired, freed and the memory reused for a different Waiter which was
199 // enqueued in the same wait-list. We would think that that waiter was our
206 // still exists. So if we find a waiter with the correct pointer value, and
209 // Case 2: the waiter hasn't been signaled yet; it was still on the wait
211 // have been enqueued with the MessageLoop because the waiter was never
218 // Case 3: the waiter isn't on the wait-list, thus it was signaled. It may not
220 // task on the SequencedTaskRunner, but to delete it instead. The Waiter
    [all...]
  /external/glide/library/src/main/java/com/bumptech/glide/request/
RequestFutureTarget.java 39 private static final Waiter DEFAULT_WAITER = new Waiter();
46 private final Waiter waiter; field in class:RequestFutureTarget
62 RequestFutureTarget(Handler mainHandler, int width, int height, boolean assertBackgroundThread, Waiter waiter) {
67 this.waiter = waiter;
83 waiter.notifyAll(this);
172 waiter.notifyAll(this)
    [all...]
  /external/eigen/unsupported/test/
cxx11_eventcount.cpp 28 MaxSizeVector<EventCount::Waiter> waiters(1);
31 EventCount::Waiter& w = waiters[0];
85 MaxSizeVector<EventCount::Waiter> waiters(kThreads);
109 EventCount::Waiter& w = waiters[i];
  /external/guice/lib/
guava-19.0.jar 

Completed in 285 milliseconds