Lines Matching refs:ThreadPool
40 class ThreadPool : SkNoncopyable {
99 explicit ThreadPool(int threads) {
104 fThreads.push(new SkThread(&ThreadPool::Loop, this));
109 ~ThreadPool() {
148 ThreadPool* pool = (ThreadPool*)arg;
186 static ThreadPool* gGlobal;
190 ThreadPool* ThreadPool::gGlobal = nullptr;
195 SkASSERT(ThreadPool::gGlobal == nullptr);
197 ThreadPool::gGlobal = new ThreadPool(threads);
201 SkTaskGroup::Enabler::~Enabler() { delete ThreadPool::gGlobal; }
205 void SkTaskGroup::wait() { ThreadPool::Wait(&fPending); }
206 void SkTaskGroup::add(std::function<void(void)> fn) { ThreadPool::Add(fn, &fPending); }
208 ThreadPool::Batch(N, fn, &fPending);
