1 // Copyright 2012 The Chromium Authors
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "base/test/test_simple_task_runner.h"
6
7 #include <optional>
8 #include <utility>
9
10 #include "base/check.h"
11 #include "base/memory/ptr_util.h"
12 #include "base/task/single_thread_task_runner.h"
13
14 namespace base {
15
16 TestSimpleTaskRunner::TestSimpleTaskRunner() = default;
17
18 TestSimpleTaskRunner::~TestSimpleTaskRunner() = default;
19
PostDelayedTask(const Location & from_here,OnceClosure task,TimeDelta delay)20 bool TestSimpleTaskRunner::PostDelayedTask(const Location& from_here,
21 OnceClosure task,
22 TimeDelta delay) {
23 AutoLock auto_lock(lock_);
24 pending_tasks_.push_back(TestPendingTask(from_here, std::move(task),
25 TimeTicks(), delay,
26 TestPendingTask::NESTABLE));
27 return true;
28 }
29
PostNonNestableDelayedTask(const Location & from_here,OnceClosure task,TimeDelta delay)30 bool TestSimpleTaskRunner::PostNonNestableDelayedTask(const Location& from_here,
31 OnceClosure task,
32 TimeDelta delay) {
33 AutoLock auto_lock(lock_);
34 pending_tasks_.push_back(TestPendingTask(from_here, std::move(task),
35 TimeTicks(), delay,
36 TestPendingTask::NON_NESTABLE));
37 return true;
38 }
39
40 // TODO(gab): Use SequenceToken here to differentiate between tasks running in
41 // the scope of this TestSimpleTaskRunner and other task runners sharing this
42 // thread. http://crbug.com/631186
RunsTasksInCurrentSequence() const43 bool TestSimpleTaskRunner::RunsTasksInCurrentSequence() const {
44 return thread_ref_ == PlatformThread::CurrentRef();
45 }
46
TakePendingTasks()47 base::circular_deque<TestPendingTask> TestSimpleTaskRunner::TakePendingTasks() {
48 AutoLock auto_lock(lock_);
49 return std::move(pending_tasks_);
50 }
51
NumPendingTasks() const52 size_t TestSimpleTaskRunner::NumPendingTasks() const {
53 AutoLock auto_lock(lock_);
54 return pending_tasks_.size();
55 }
56
HasPendingTask() const57 bool TestSimpleTaskRunner::HasPendingTask() const {
58 AutoLock auto_lock(lock_);
59 return !pending_tasks_.empty();
60 }
61
NextPendingTaskDelay() const62 base::TimeDelta TestSimpleTaskRunner::NextPendingTaskDelay() const {
63 AutoLock auto_lock(lock_);
64 return pending_tasks_.front().GetTimeToRun() - base::TimeTicks();
65 }
66
FinalPendingTaskDelay() const67 base::TimeDelta TestSimpleTaskRunner::FinalPendingTaskDelay() const {
68 AutoLock auto_lock(lock_);
69 return pending_tasks_.back().GetTimeToRun() - base::TimeTicks();
70 }
71
ClearPendingTasks()72 void TestSimpleTaskRunner::ClearPendingTasks() {
73 AutoLock auto_lock(lock_);
74 pending_tasks_.clear();
75 }
76
RunPendingTasks()77 void TestSimpleTaskRunner::RunPendingTasks() {
78 DCHECK(RunsTasksInCurrentSequence());
79
80 // Swap with a local variable to avoid re-entrancy problems.
81 base::circular_deque<TestPendingTask> tasks_to_run;
82 {
83 AutoLock auto_lock(lock_);
84 tasks_to_run.swap(pending_tasks_);
85 }
86
87 // Multiple test task runners can share the same thread for determinism in
88 // unit tests. Make sure this TestSimpleTaskRunner's tasks run in its scope.
89 std::optional<SingleThreadTaskRunner::CurrentHandleOverrideForTesting>
90 ttrh_override;
91 if (!SingleThreadTaskRunner::HasCurrentDefault() ||
92 SingleThreadTaskRunner::GetCurrentDefault() != this) {
93 ttrh_override.emplace(this);
94 }
95
96 for (auto& task : tasks_to_run)
97 std::move(task.task).Run();
98 }
99
RunUntilIdle()100 void TestSimpleTaskRunner::RunUntilIdle() {
101 while (HasPendingTask())
102 RunPendingTasks();
103 }
104
105 } // namespace base
106