Home | History | Annotate | Download | only in threading

Lines Matching refs:pool_

22       : pool_(pool) {}
24 Lock* lock() { return &pool_->lock_; }
26 return &pool_->tasks_available_cv_;
28 const std::queue<Task*>& tasks() const { return pool_->tasks_; }
29 int num_idle_threads() const { return pool_->num_idle_threads_; }
31 return pool_->num_idle_threads_cv_.get();
34 pool_->num_idle_threads_cv_.reset(cv);
38 PosixDynamicThreadPool* pool_;
124 : pool_(new base::PosixDynamicThreadPool("dynamic_pool", 60*60)),
125 peer_(pool_.get()),
137 if (pool_.get()) pool_->Terminate();
166 scoped_refptr<base::PosixDynamicThreadPool> pool_;
186 pool_->PostTask(CreateNewIncrementingTask());
198 pool_->PostTask(CreateNewIncrementingTask());
203 pool_->PostTask(CreateNewBlockingIncrementingTask());
204 pool_->PostTask(CreateNewBlockingIncrementingTask());
217 pool_->PostTask(CreateNewBlockingIncrementingTask());
218 pool_->PostTask(CreateNewBlockingIncrementingTask());
233 pool_->PostTask(CreateNewIncrementingTask());
239 pool_->PostTask(CreateNewBlockingIncrementingTask());
240 pool_->PostTask(CreateNewBlockingIncrementingTask());
260 pool_->PostTask(CreateNewIncrementingTask());