Searched refs:waiters_ (Results 1 - 5 of 5) sorted by relevance

/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
H A DSimpleThreadPool.h25 : env_(env), threads_(num_threads), waiters_(num_threads) {
43 for (auto w : waiters_) {
61 if (waiters_.empty()) {
64 Waiter* w = waiters_.back();
65 waiters_.pop_back();
97 waiters_.push_back(&w);
139 MaxSizeVector<Waiter*> waiters_; // Stack of waiting threads. member in class:Eigen::SimpleThreadPoolTempl
H A DEventCount.h53 EventCount(MaxSizeVector<Waiter>& waiters) : waiters_(waiters) {
93 newstate = (newstate & ~kStackMask) | (w - &waiters_[0]);
97 w->next.store(&waiters_[state & kStackMask], std::memory_order_relaxed);
148 Waiter* w = &waiters_[state & kStackMask];
151 if (wnext != nullptr) next = wnext - &waiters_[0];
162 Waiter* w = &waiters_[state & kStackMask];
202 MaxSizeVector<Waiter>& waiters_; member in class:Eigen::EventCount
H A DNonBlockingThreadPool.h27 waiters_(num_threads),
31 ec_(waiters_) {
32 waiters_.resize(num_threads);
128 MaxSizeVector<EventCount::Waiter> waiters_; member in class:Eigen::NonBlockingThreadPoolTempl
141 EventCount::Waiter* waiter = &waiters_[thread_id];
/external/libchrome/base/synchronization/
H A Dwaitable_event_posix.cc365 i = kernel_->waiters_.begin(); i != kernel_->waiters_.end(); ++i) {
370 kernel_->waiters_.clear();
380 if (kernel_->waiters_.empty())
383 const bool r = (*kernel_->waiters_.begin())->Fire(this);
384 kernel_->waiters_.pop_front();
394 kernel_->waiters_.push_back(waiter);
403 i = waiters_.begin(); i != waiters_.end(); ++i) {
405 waiters_
[all...]
H A Dwaitable_event.h167 std::list<Waiter*> waiters_; member in struct:base::WaitableEvent::WaitableEventKernel

Completed in 117 milliseconds