Searched refs:queue_waiters_ (Results 1 – 2 of 2) sorted by relevance
136 queue_waiters_.next = &queue_waiters_; in ThreadWorkSource()137 queue_waiters_.prev = &queue_waiters_; in ThreadWorkSource()187 waiter_queue = &queue_waiters_; in EnqueueTask()242 WaitOnWaiter(&waiter, &queue_waiters_, &waiters_mu_, max_sleep_micros); in WaitForWork()325 queue_waiters_(queue_waiters), in RunHandlerThreadPool()662 WaitOnWaiter(&waiter, &(*queue_waiters_)[sub_thread_pool_id], in WaitForWorkInSubThreadPool()776 queue_waiters_( in Impl()781 &queue_waiters_)), in Impl()794 queue_waiters_.resize(798 for (auto& queue_waiter : queue_waiters_) {[all …]
205 Waiter queue_waiters_ TF_GUARDED_BY(waiters_mu_);298 Eigen::MaxSizeVector<Waiter>* queue_waiters_; variable