Home
last modified time | relevance | path

Searched refs:waiters_ (Results 1 – 7 of 7) sorted by relevance

/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
DSimpleThreadPool.h25 : env_(env), threads_(num_threads), waiters_(num_threads) { in env_()
43 for (auto w : waiters_) { in ~SimpleThreadPoolTempl()
61 if (waiters_.empty()) { in Schedule()
64 Waiter* w = waiters_.back(); in Schedule()
65 waiters_.pop_back(); in Schedule()
97 waiters_.push_back(&w); in WorkerLoop()
139 MaxSizeVector<Waiter*> waiters_; // Stack of waiting threads. variable
DEventCount.h53 EventCount(MaxSizeVector<Waiter>& waiters) : waiters_(waiters) { in EventCount()
93 newstate = (newstate & ~kStackMask) | (w - &waiters_[0]); in CommitWait()
97 w->next.store(&waiters_[state & kStackMask], std::memory_order_relaxed); in CommitWait()
148 Waiter* w = &waiters_[state & kStackMask]; in Notify()
151 if (wnext != nullptr) next = wnext - &waiters_[0]; in Notify()
162 Waiter* w = &waiters_[state & kStackMask]; in Notify()
202 MaxSizeVector<Waiter>& waiters_; variable
DNonBlockingThreadPool.h27 waiters_(num_threads), in env_()
31 ec_(waiters_) { in env_()
32 waiters_.resize(num_threads); in env_()
128 MaxSizeVector<EventCount::Waiter> waiters_; variable
141 EventCount::Waiter* waiter = &waiters_[thread_id]; in WorkerLoop()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/
Dmpmcqueue.cc90 waiters_.next = &waiters_; in InfLenFIFOQueue()
91 waiters_.prev = &waiters_; in InfLenFIFOQueue()
169 waiter->next = waiters_.next; in PushWaiter()
170 waiter->prev = &waiters_; in PushWaiter()
176 GPR_DEBUG_ASSERT(waiter != &waiters_); in RemoveWaiter()
181 InfLenFIFOQueue::Waiter* InfLenFIFOQueue::TopWaiter() { return waiters_.next; } in TopWaiter()
Dmpmcqueue.h145 Waiter waiters_; // Head of waiting thread queue variable
/external/libchrome/base/synchronization/
Dwaitable_event_posix.cc386 i = kernel_->waiters_.begin(); i != kernel_->waiters_.end(); ++i) { in SignalAll()
391 kernel_->waiters_.clear(); in SignalAll()
401 if (kernel_->waiters_.empty()) in SignalOne()
404 const bool r = (*kernel_->waiters_.begin())->Fire(this); in SignalOne()
405 kernel_->waiters_.pop_front(); in SignalOne()
415 kernel_->waiters_.push_back(waiter); in Enqueue()
424 i = waiters_.begin(); i != waiters_.end(); ++i) { in Dequeue()
426 waiters_.erase(i); in Dequeue()
Dwaitable_event.h255 std::list<Waiter*> waiters_; member