Searched refs:waiters_ (Results 1 – 5 of 5) sorted by relevance
25 : 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
53 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
27 waiters_(num_threads), in env_()31 ec_(waiters_) { in env_()32 waiters_.resize(num_threads); in env_()128 MaxSizeVector<EventCount::Waiter> waiters_; variable141 EventCount::Waiter* waiter = &waiters_[thread_id]; in WorkerLoop()
386 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()
255 std::list<Waiter*> waiters_; member