OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/test/scoped_task_scheduler.h" | 5 #include "base/test/scoped_task_scheduler.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <utility> | 8 #include <utility> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
42 public: | 42 public: |
43 // |external_message_loop| is an externally provided MessageLoop on which to | 43 // |external_message_loop| is an externally provided MessageLoop on which to |
44 // run tasks. A MessageLoop will be created by TestTaskScheduler if | 44 // run tasks. A MessageLoop will be created by TestTaskScheduler if |
45 // |external_message_loop| is nullptr. | 45 // |external_message_loop| is nullptr. |
46 explicit TestTaskScheduler(MessageLoop* external_message_loop); | 46 explicit TestTaskScheduler(MessageLoop* external_message_loop); |
47 ~TestTaskScheduler() override; | 47 ~TestTaskScheduler() override; |
48 | 48 |
49 // TaskScheduler: | 49 // TaskScheduler: |
50 void PostDelayedTaskWithTraits(const tracked_objects::Location& from_here, | 50 void PostDelayedTaskWithTraits(const tracked_objects::Location& from_here, |
51 const TaskTraits& traits, | 51 const TaskTraits& traits, |
52 Closure task, | 52 OnceClosure task, |
53 TimeDelta delay) override; | 53 TimeDelta delay) override; |
54 scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits( | 54 scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits( |
55 const TaskTraits& traits) override; | 55 const TaskTraits& traits) override; |
56 scoped_refptr<SequencedTaskRunner> CreateSequencedTaskRunnerWithTraits( | 56 scoped_refptr<SequencedTaskRunner> CreateSequencedTaskRunnerWithTraits( |
57 const TaskTraits& traits) override; | 57 const TaskTraits& traits) override; |
58 scoped_refptr<SingleThreadTaskRunner> CreateSingleThreadTaskRunnerWithTraits( | 58 scoped_refptr<SingleThreadTaskRunner> CreateSingleThreadTaskRunnerWithTraits( |
59 const TaskTraits& traits) override; | 59 const TaskTraits& traits) override; |
60 #if defined(OS_WIN) | 60 #if defined(OS_WIN) |
61 scoped_refptr<SingleThreadTaskRunner> CreateCOMSTATaskRunnerWithTraits( | 61 scoped_refptr<SingleThreadTaskRunner> CreateCOMSTATaskRunnerWithTraits( |
62 const TaskTraits& traits) override; | 62 const TaskTraits& traits) override; |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
127 }; | 127 }; |
128 | 128 |
129 class TestTaskSchedulerTaskRunner : public SingleThreadTaskRunner { | 129 class TestTaskSchedulerTaskRunner : public SingleThreadTaskRunner { |
130 public: | 130 public: |
131 TestTaskSchedulerTaskRunner(TestTaskScheduler* task_scheduler, | 131 TestTaskSchedulerTaskRunner(TestTaskScheduler* task_scheduler, |
132 ExecutionMode execution_mode, | 132 ExecutionMode execution_mode, |
133 TaskTraits traits); | 133 TaskTraits traits); |
134 | 134 |
135 // SingleThreadTaskRunner: | 135 // SingleThreadTaskRunner: |
136 bool PostDelayedTask(const tracked_objects::Location& from_here, | 136 bool PostDelayedTask(const tracked_objects::Location& from_here, |
137 Closure closure, | 137 OnceClosure closure, |
138 TimeDelta delay) override; | 138 TimeDelta delay) override; |
139 bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here, | 139 bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here, |
140 Closure closure, | 140 OnceClosure closure, |
141 TimeDelta delay) override; | 141 TimeDelta delay) override; |
142 bool RunsTasksOnCurrentThread() const override; | 142 bool RunsTasksOnCurrentThread() const override; |
143 | 143 |
144 private: | 144 private: |
145 ~TestTaskSchedulerTaskRunner() override; | 145 ~TestTaskSchedulerTaskRunner() override; |
146 | 146 |
147 TestTaskScheduler* const task_scheduler_; | 147 TestTaskScheduler* const task_scheduler_; |
148 const ExecutionMode execution_mode_; | 148 const ExecutionMode execution_mode_; |
149 const SequenceToken sequence_token_; | 149 const SequenceToken sequence_token_; |
150 const TaskTraits traits_; | 150 const TaskTraits traits_; |
151 | 151 |
152 DISALLOW_COPY_AND_ASSIGN(TestTaskSchedulerTaskRunner); | 152 DISALLOW_COPY_AND_ASSIGN(TestTaskSchedulerTaskRunner); |
153 }; | 153 }; |
154 | 154 |
155 TestTaskScheduler::TestTaskScheduler(MessageLoop* external_message_loop) | 155 TestTaskScheduler::TestTaskScheduler(MessageLoop* external_message_loop) |
156 : message_loop_owned_(external_message_loop ? nullptr | 156 : message_loop_owned_(external_message_loop ? nullptr |
157 : MakeUnique<MessageLoop>()), | 157 : MakeUnique<MessageLoop>()), |
158 message_loop_(message_loop_owned_ ? message_loop_owned_.get() | 158 message_loop_(message_loop_owned_ ? message_loop_owned_.get() |
159 : external_message_loop) {} | 159 : external_message_loop) {} |
160 | 160 |
161 TestTaskScheduler::~TestTaskScheduler() { | 161 TestTaskScheduler::~TestTaskScheduler() { |
162 // Shutdown if it hasn't already been done explicitly. | 162 // Shutdown if it hasn't already been done explicitly. |
163 if (!task_tracker_.HasShutdownStarted()) | 163 if (!task_tracker_.HasShutdownStarted()) |
164 Shutdown(); | 164 Shutdown(); |
165 } | 165 } |
166 | 166 |
167 void TestTaskScheduler::PostDelayedTaskWithTraits( | 167 void TestTaskScheduler::PostDelayedTaskWithTraits( |
168 const tracked_objects::Location& from_here, | 168 const tracked_objects::Location& from_here, |
169 const TaskTraits& traits, | 169 const TaskTraits& traits, |
170 Closure task, | 170 OnceClosure task, |
171 TimeDelta delay) { | 171 TimeDelta delay) { |
172 CreateTaskRunnerWithTraits(traits)->PostDelayedTask(from_here, | 172 CreateTaskRunnerWithTraits(traits)->PostDelayedTask(from_here, |
173 std::move(task), delay); | 173 std::move(task), delay); |
174 } | 174 } |
175 | 175 |
176 scoped_refptr<TaskRunner> TestTaskScheduler::CreateTaskRunnerWithTraits( | 176 scoped_refptr<TaskRunner> TestTaskScheduler::CreateTaskRunnerWithTraits( |
177 const TaskTraits& traits) { | 177 const TaskTraits& traits) { |
178 return make_scoped_refptr( | 178 return make_scoped_refptr( |
179 new TestTaskSchedulerTaskRunner(this, ExecutionMode::PARALLEL, traits)); | 179 new TestTaskSchedulerTaskRunner(this, ExecutionMode::PARALLEL, traits)); |
180 } | 180 } |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
273 TaskTraits traits) | 273 TaskTraits traits) |
274 : task_scheduler_(task_scheduler), | 274 : task_scheduler_(task_scheduler), |
275 execution_mode_(execution_mode), | 275 execution_mode_(execution_mode), |
276 sequence_token_(execution_mode == ExecutionMode::PARALLEL | 276 sequence_token_(execution_mode == ExecutionMode::PARALLEL |
277 ? SequenceToken() | 277 ? SequenceToken() |
278 : SequenceToken::Create()), | 278 : SequenceToken::Create()), |
279 traits_(traits) {} | 279 traits_(traits) {} |
280 | 280 |
281 bool TestTaskSchedulerTaskRunner::PostDelayedTask( | 281 bool TestTaskSchedulerTaskRunner::PostDelayedTask( |
282 const tracked_objects::Location& from_here, | 282 const tracked_objects::Location& from_here, |
283 Closure closure, | 283 OnceClosure closure, |
284 TimeDelta delay) { | 284 TimeDelta delay) { |
285 auto task = | 285 auto task = |
286 MakeUnique<internal::Task>(from_here, std::move(closure), traits_, delay); | 286 MakeUnique<internal::Task>(from_here, std::move(closure), traits_, delay); |
287 if (execution_mode_ == ExecutionMode::SEQUENCED) | 287 if (execution_mode_ == ExecutionMode::SEQUENCED) |
288 task->sequenced_task_runner_ref = make_scoped_refptr(this); | 288 task->sequenced_task_runner_ref = make_scoped_refptr(this); |
289 else if (execution_mode_ == ExecutionMode::SINGLE_THREADED) | 289 else if (execution_mode_ == ExecutionMode::SINGLE_THREADED) |
290 task->single_thread_task_runner_ref = make_scoped_refptr(this); | 290 task->single_thread_task_runner_ref = make_scoped_refptr(this); |
291 return task_scheduler_->PostTask(std::move(task), sequence_token_); | 291 return task_scheduler_->PostTask(std::move(task), sequence_token_); |
292 } | 292 } |
293 | 293 |
294 bool TestTaskSchedulerTaskRunner::PostNonNestableDelayedTask( | 294 bool TestTaskSchedulerTaskRunner::PostNonNestableDelayedTask( |
295 const tracked_objects::Location& from_here, | 295 const tracked_objects::Location& from_here, |
296 Closure closure, | 296 OnceClosure closure, |
297 TimeDelta delay) { | 297 TimeDelta delay) { |
298 // Tasks are never nested within the task scheduler. | 298 // Tasks are never nested within the task scheduler. |
299 return PostDelayedTask(from_here, std::move(closure), delay); | 299 return PostDelayedTask(from_here, std::move(closure), delay); |
300 } | 300 } |
301 | 301 |
302 bool TestTaskSchedulerTaskRunner::RunsTasksOnCurrentThread() const { | 302 bool TestTaskSchedulerTaskRunner::RunsTasksOnCurrentThread() const { |
303 if (execution_mode_ == ExecutionMode::PARALLEL) | 303 if (execution_mode_ == ExecutionMode::PARALLEL) |
304 return task_scheduler_->RunsTasksOnCurrentThread(); | 304 return task_scheduler_->RunsTasksOnCurrentThread(); |
305 return sequence_token_ == SequenceToken::GetForCurrentThread(); | 305 return sequence_token_ == SequenceToken::GetForCurrentThread(); |
306 } | 306 } |
(...skipping 15 matching lines...) Expand all Loading... |
322 DCHECK_EQ(task_scheduler_, TaskScheduler::GetInstance()); | 322 DCHECK_EQ(task_scheduler_, TaskScheduler::GetInstance()); |
323 | 323 |
324 // Per contract, call JoinForTesting() before deleting the TaskScheduler. | 324 // Per contract, call JoinForTesting() before deleting the TaskScheduler. |
325 TaskScheduler::GetInstance()->JoinForTesting(); | 325 TaskScheduler::GetInstance()->JoinForTesting(); |
326 | 326 |
327 TaskScheduler::SetInstance(nullptr); | 327 TaskScheduler::SetInstance(nullptr); |
328 } | 328 } |
329 | 329 |
330 } // namespace test | 330 } // namespace test |
331 } // namespace base | 331 } // namespace base |
OLD | NEW |