OLD | NEW |
1 #include "SkTaskGroup.h" | 1 #include "SkTaskGroup.h" |
2 | 2 |
3 #include "SkCondVar.h" | 3 #include "SkCondVar.h" |
| 4 #include "SkRunnable.h" |
4 #include "SkTDArray.h" | 5 #include "SkTDArray.h" |
5 #include "SkThread.h" | 6 #include "SkThread.h" |
6 #include "SkThreadUtils.h" | 7 #include "SkThreadUtils.h" |
7 | 8 |
8 #if defined(SK_BUILD_FOR_WIN32) | 9 #if defined(SK_BUILD_FOR_WIN32) |
9 static inline int num_cores() { | 10 static inline int num_cores() { |
10 SYSTEM_INFO sysinfo; | 11 SYSTEM_INFO sysinfo; |
11 GetSystemInfo(&sysinfo); | 12 GetSystemInfo(&sysinfo); |
12 return sysinfo.dwNumberOfProcessors; | 13 return sysinfo.dwNumberOfProcessors; |
13 } | 14 } |
(...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
151 SkTaskGroup::Enabler::~Enabler() { | 152 SkTaskGroup::Enabler::~Enabler() { |
152 SkDELETE(ThreadPool::gGlobal); | 153 SkDELETE(ThreadPool::gGlobal); |
153 } | 154 } |
154 | 155 |
155 SkTaskGroup::SkTaskGroup() : fPending(0) {} | 156 SkTaskGroup::SkTaskGroup() : fPending(0) {} |
156 | 157 |
157 void SkTaskGroup::add(SkRunnable* task) { ThreadPool::Add(task, &fPe
nding); } | 158 void SkTaskGroup::add(SkRunnable* task) { ThreadPool::Add(task, &fPe
nding); } |
158 void SkTaskGroup::add(void (*fn)(void*), void* arg) { ThreadPool::Add(fn, arg, &
fPending); } | 159 void SkTaskGroup::add(void (*fn)(void*), void* arg) { ThreadPool::Add(fn, arg, &
fPending); } |
159 void SkTaskGroup::wait() { ThreadPool::Wait(&fPending
); } | 160 void SkTaskGroup::wait() { ThreadPool::Wait(&fPending
); } |
160 | 161 |
OLD | NEW |