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

  /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
SimpleThreadPool.h 25 : 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
EventCount.h 53 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
NonBlockingThreadPool.h 27 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/
waitable_event_posix.cc 386 i = kernel_->waiters_.begin(); i != kernel_->waiters_.end(); ++i) {
391 kernel_->waiters_.clear();
401 if (kernel_->waiters_.empty())
404 const bool r = (*kernel_->waiters_.begin())->Fire(this);
405 kernel_->waiters_.pop_front();
415 kernel_->waiters_.push_back(waiter);
424 i = waiters_.begin(); i != waiters_.end(); ++i) {
426 waiters_.erase(i)
    [all...]
waitable_event.h 255 std::list<Waiter*> waiters_; member in struct:base::WaitableEvent::WaitableEventKernel
  /art/openjdkjvmti/
ti_object.cc 102 for (art::Thread* thd : info.waiters_) {
  /art/runtime/
monitor.h 390 std::vector<Thread*> waiters_; member in class:art::MonitorInfo
monitor.cc     [all...]
debugger.cc 873 expandBufAdd4BE(reply, monitor_info.waiters_.size());
874 for (size_t i = 0; i < monitor_info.waiters_.size(); ++i) {
875 expandBufAddObjectId(reply, gRegistry->Add(monitor_info.waiters_[i]->GetPeerFromOtherThread()));
    [all...]

Completed in 951 milliseconds