Searched refs:compute_pool (Results 1 – 7 of 7) sorted by relevance
61 static thread::ThreadPool* compute_pool = InitComputePool(options); in ComputePool() local62 return compute_pool; in ComputePool()
66 thread::ThreadPool* compute_pool = nullptr; member
144 worker_env_->compute_pool, cluster_flr)); in InitItem()500 thread::ThreadPool* pool = worker_env_->compute_pool; in StartParallelExecutors()
48 env_->compute_pool->Schedule([this, call]() { \
271 worker_env_2->compute_pool->Schedule([this, step_id, parsed, done_cb]() { in AddRequest()
249 worker_env_.compute_pool = ComputePool(sess_opts); in Init()
173 worker_->env()->compute_pool->Schedule(std::move(f)); in Schedule()