1d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com#include "DMTaskRunner.h" 2d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com#include "DMTask.h" 3d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com 4d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.comnamespace DM { 5d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com 6ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.orgTaskRunner::TaskRunner(int cpuThreads, int gpuThreads) : fCpu(cpuThreads), fGpu(gpuThreads) {} 70dc5bd149a8b69e8dc6d3b4713b827659c9b0a6bcommit-bot@chromium.org 8ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.orgvoid TaskRunner::add(CpuTask* task) { fCpu.add(task); } 93f032156c8b5d4decb0beccdc2cdbcf91867fa36commit-bot@chromium.orgvoid TaskRunner::addNext(CpuTask* task) { fCpu.addNext(task); } 10ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.orgvoid TaskRunner::add(GpuTask* task) { fGpu.add(task); } 11d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com 12d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.comvoid TaskRunner::wait() { 13ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.org // These wait calls block until each threadpool is done. We don't allow 14ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.org // spawning new child GPU tasks, so we can wait for that first knowing 15ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.org // we'll never try to add to it later. Same can't be said of the CPU pool: 16ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.org // both CPU and GPU tasks can spawn off new CPU work, so we wait for that last. 17d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com fGpu.wait(); 18ef57b7e65330d5f794a513630517907500f1c1d0commit-bot@chromium.org fCpu.wait(); 19d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com} 20d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com 21d36522d12d3e71958e50683a7eef43dc2a47d96dmtklein@google.com} // namespace DM 22