Lines Matching defs:ThreadPool
23 class ThreadPool : SkNoncopyable {
69 explicit ThreadPool(int threads) : fDraining(false) {
74 fThreads.push(SkNEW_ARGS(SkThread, (&ThreadPool::Loop, this)));
79 ~ThreadPool() {
104 ThreadPool* pool = (ThreadPool*)arg;
127 static ThreadPool* gGlobal;
130 ThreadPool* ThreadPool::gGlobal = NULL;
135 SkASSERT(ThreadPool::gGlobal == NULL);
136 ThreadPool::gGlobal = SkNEW_ARGS(ThreadPool, (threads));
140 SkASSERT(ThreadPool::gGlobal != NULL);
141 SkDELETE(ThreadPool::gGlobal);
146 void SkTaskGroup::add(SkRunnable* task) { ThreadPool::Add(task, &fPending); }
147 void SkTaskGroup::wait() { ThreadPool::Wait(&fPending); }
