task_runner.cc 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. // Copyright 2019 The Chromium Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file.
  4. #include <chrono> // NOLINT
  5. #include <utility>
  6. #include "base/bind.h"
  7. #include "base/location.h"
  8. #include "base/task/task_traits.h"
  9. #include "base/time/time.h"
  10. #include "components/openscreen_platform/task_runner.h"
  11. namespace openscreen_platform {
  12. using openscreen::Clock;
  13. using Task = openscreen::TaskRunner::Task;
  14. namespace {
  15. void ExecuteTask(Task task) {
  16. task();
  17. }
  18. } // namespace
  19. TaskRunner::TaskRunner(scoped_refptr<base::SequencedTaskRunner> task_runner) {
  20. task_runner_ = task_runner;
  21. }
  22. TaskRunner::~TaskRunner() = default;
  23. void TaskRunner::PostPackagedTask(Task task) {
  24. task_runner_->PostTask(FROM_HERE,
  25. base::BindOnce(ExecuteTask, std::move(task)));
  26. }
  27. void TaskRunner::PostPackagedTaskWithDelay(Task task, Clock::duration delay) {
  28. auto time_delta = base::Microseconds(
  29. std::chrono::duration_cast<std::chrono::microseconds>(delay).count());
  30. task_runner_->PostDelayedTask(
  31. FROM_HERE, base::BindOnce(ExecuteTask, std::move(task)), time_delta);
  32. }
  33. bool TaskRunner::IsRunningOnTaskRunner() {
  34. return task_runner_->RunsTasksInCurrentSequence();
  35. }
  36. } // namespace openscreen_platform