Searched refs:waiters_ (Results 1 – 7 of 7) sorted by relevance
| /third_party/boost/boost/thread/ |
| D | completion_latch.hpp | 55 that_.waiters_.inc_and_notify_all(); in around_wait()
60 that_.waiters_.dec_and_notify_all(); in ~around_wait()
69 waiters_.cond_.wait(lk, detail::counter_is_not_zero(waiters_)); in count_down()
70 leavers_.assign_and_notify_all(waiters_); in count_down()
72 waiters_.cond_.wait(lk, detail::counter_is_zero(waiters_)); in count_down()
86 count_(count), funct_(noop()), waiters_(0), leavers_(0) in completion_latch()
95 waiters_(0), in completion_latch()
100 count_(count), funct_(funct), waiters_(0), leavers_(0) in completion_latch()
217 detail::counter waiters_; member in boost::completion_latch
|
| /third_party/boost/boost/thread/futures/ |
| D | wait_for_any.hpp | 85 std::vector<registered_waiter> waiters_; member in boost::detail::waiter_for_any_in_seq
102 waiters_.push_back(waiter); in add()
124 all_futures_lock lk(waiters_); in wait()
127 for (count_type i = 0; i < waiters_.size(); ++i) in wait()
129 if (waiters_[i].future_->is_ready(lk.locks[i])) in wait()
131 return waiters_[i].index; in wait()
140 for (count_type i = 0; i < waiters_.size(); ++i) in ~waiter_for_any_in_seq()
142 waiters_[i].future_->unnotify_when_ready(waiters_[i].handle); in ~waiter_for_any_in_seq()
|
| /third_party/flutter/engine/flutter/shell/platform/fuchsia/dart-pkg/zircon/sdk_ext/ |
| D | handle.cc | 63 while (waiters_.size()) { in ReleaseHandle()
66 FML_DCHECK(waiters_.back()->is_pending()); in ReleaseHandle()
67 waiters_.back()->Cancel(); in ReleaseHandle()
92 waiters_.push_back(waiter.get()); in AsyncWait()
99 auto iter = std::find(waiters_.cbegin(), waiters_.cend(), waiter); in ReleaseWaiter()
100 FML_DCHECK(iter != waiters_.cend()); in ReleaseWaiter()
102 waiters_.erase(iter); in ReleaseWaiter()
|
| D | handle.h | 76 std::vector<HandleWaiter*> waiters_; variable
|
| /third_party/grpc/src/core/lib/iomgr/executor/ |
| D | mpmcqueue.cc | 90 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()
|
| D | mpmcqueue.h | 145 Waiter waiters_; // Head of waiting thread queue variable
|
| /third_party/boost/boost/fiber/future/detail/ |
| D | shared_state.hpp | 40 mutable condition_variable waiters_{}; member in boost::fibers::detail::shared_state_base
51 waiters_.notify_all(); in mark_ready_and_notify_()
80 waiters_.wait( lk, [this](){ return ready_; }); in wait_()
87 return waiters_.wait_for( lk, timeout_duration, [this](){ return ready_; }) in wait_for_()
96 return waiters_.wait_until( lk, timeout_time, [this](){ return ready_; }) in wait_until_()
|