Searched refs:work_queue_mu_ (Results 1 – 2 of 2) sorted by relevance
56 mutex work_queue_mu_; variable57 condition_variable work_queue_cv_ TF_GUARDED_BY(work_queue_mu_);58 size_t num_idle_threads_ TF_GUARDED_BY(work_queue_mu_) = 0;59 bool cancelled_ TF_GUARDED_BY(work_queue_mu_) = false;60 std::deque<WorkFunction> work_queue_ TF_GUARDED_BY(work_queue_mu_);
31 mutex_lock l(work_queue_mu_); in ~UnboundedWorkQueue()58 mutex_lock l(work_queue_mu_); in Schedule()84 mutex_lock l(work_queue_mu_); in PooledThreadFunc()