OLD | NEW |
1 #ifndef DMTaskRunner_DEFINED | 1 #ifndef DMTaskRunner_DEFINED |
2 #define DMTaskRunner_DEFINED | 2 #define DMTaskRunner_DEFINED |
3 | 3 |
4 #include "DMGpuSupport.h" | 4 #include "DMGpuSupport.h" |
5 #include "SkThreadPool.h" | 5 #include "SkTDArray.h" |
| 6 #include "SkTaskGroup.h" |
6 #include "SkTypes.h" | 7 #include "SkTypes.h" |
7 | 8 |
8 // TaskRunner runs Tasks on one of two threadpools depending on the need for a G
rContextFactory. | 9 // TaskRunner runs Tasks on one of two threadpools depending on the need for a G
rContextFactory. |
9 // It's typically a good idea to run fewer GPU threads than CPU threads (go nuts
with those). | 10 // We fix the number of GPU threads to 1, but go nuts with CPU threads. |
10 | 11 |
11 namespace DM { | 12 namespace DM { |
12 | 13 |
13 class CpuTask; | 14 class CpuTask; |
14 class GpuTask; | 15 class GpuTask; |
15 | 16 |
16 class TaskRunner : SkNoncopyable { | 17 class TaskRunner : SkNoncopyable { |
17 public: | 18 public: |
18 explicit TaskRunner(int cpuThreads, int gpuThreads); | 19 // 0 -> one thread per core |
| 20 explicit TaskRunner(int cpuThreads); |
19 | 21 |
20 void add(CpuTask* task); | 22 void add(CpuTask* task); |
21 void addNext(CpuTask* task); | |
22 void add(GpuTask* task); | 23 void add(GpuTask* task); |
23 void wait(); | 24 void wait(); |
24 | 25 |
25 private: | 26 private: |
26 SkTThreadPool<void> fCpu; | 27 SkTaskGroup fCpuWork; |
27 SkTThreadPool<GrContextFactory> fGpu; | 28 SkTDArray<GpuTask*> fGpuWork; |
28 }; | 29 }; |
29 | 30 |
30 } // namespace DM | 31 } // namespace DM |
31 | 32 |
32 #endif // DMTaskRunner_DEFINED | 33 #endif // DMTaskRunner_DEFINED |
OLD | NEW |