| 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/task_scheduler/test_task_factory.h" | 5 #include "base/task_scheduler/test_task_factory.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/callback.h" | 9 #include "base/callback.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| 11 #include "base/logging.h" | 11 #include "base/logging.h" |
| 12 #include "base/synchronization/waitable_event.h" | 12 #include "base/synchronization/waitable_event.h" |
| 13 #include "base/threading/sequenced_task_runner_handle.h" | 13 #include "base/threading/task_runner_handle.h" |
| 14 #include "base/threading/thread_task_runner_handle.h" | |
| 15 #include "testing/gtest/include/gtest/gtest.h" | 14 #include "testing/gtest/include/gtest/gtest.h" |
| 16 | 15 |
| 17 namespace base { | 16 namespace base { |
| 18 namespace internal { | 17 namespace internal { |
| 19 namespace test { | 18 namespace test { |
| 20 | 19 |
| 21 TestTaskFactory::TestTaskFactory(scoped_refptr<TaskRunner> task_runner, | 20 TestTaskFactory::TestTaskFactory(scoped_refptr<TaskRunner> task_runner, |
| 22 ExecutionMode execution_mode) | 21 ExecutionMode execution_mode) |
| 23 : cv_(&lock_), | 22 : cv_(&lock_), |
| 24 task_runner_(std::move(task_runner)), | 23 task_runner_(std::move(task_runner)), |
| (...skipping 26 matching lines...) Expand all Loading... |
| 51 PostNestedTask post_nested_task, | 50 PostNestedTask post_nested_task, |
| 52 const Closure& after_task_closure) { | 51 const Closure& after_task_closure) { |
| 53 if (post_nested_task == PostNestedTask::YES) | 52 if (post_nested_task == PostNestedTask::YES) |
| 54 PostTask(PostNestedTask::NO, Closure()); | 53 PostTask(PostNestedTask::NO, Closure()); |
| 55 | 54 |
| 56 EXPECT_TRUE(task_runner_->RunsTasksOnCurrentThread()); | 55 EXPECT_TRUE(task_runner_->RunsTasksOnCurrentThread()); |
| 57 | 56 |
| 58 // Verify TaskRunnerHandles are set as expected in the task's scope. | 57 // Verify TaskRunnerHandles are set as expected in the task's scope. |
| 59 switch (execution_mode_) { | 58 switch (execution_mode_) { |
| 60 case ExecutionMode::PARALLEL: | 59 case ExecutionMode::PARALLEL: |
| 61 EXPECT_FALSE(ThreadTaskRunnerHandle::IsSet()); | 60 EXPECT_FALSE(TaskRunnerHandle::HasSingleThreadTaskScope()); |
| 62 EXPECT_FALSE(SequencedTaskRunnerHandle::IsSet()); | 61 EXPECT_FALSE(TaskRunnerHandle::HasSequencedTaskScope()); |
| 63 break; | 62 break; |
| 64 case ExecutionMode::SEQUENCED: | 63 case ExecutionMode::SEQUENCED: |
| 65 EXPECT_FALSE(ThreadTaskRunnerHandle::IsSet()); | 64 EXPECT_FALSE(TaskRunnerHandle::HasSingleThreadTaskScope()); |
| 66 EXPECT_TRUE(SequencedTaskRunnerHandle::IsSet()); | 65 EXPECT_TRUE(TaskRunnerHandle::HasSequencedTaskScope()); |
| 67 EXPECT_EQ(task_runner_, SequencedTaskRunnerHandle::Get()); | 66 EXPECT_EQ(task_runner_, TaskRunnerHandle::GetSequenced()); |
| 68 break; | 67 break; |
| 69 case ExecutionMode::SINGLE_THREADED: | 68 case ExecutionMode::SINGLE_THREADED: |
| 70 // SequencedTaskRunnerHandle inherits from ThreadTaskRunnerHandle so | 69 EXPECT_TRUE(TaskRunnerHandle::HasSingleThreadTaskScope()); |
| 71 // both are expected to be "set" in the SINGLE_THREADED case. | 70 EXPECT_TRUE(TaskRunnerHandle::HasSequencedTaskScope()); |
| 72 EXPECT_TRUE(ThreadTaskRunnerHandle::IsSet()); | 71 EXPECT_EQ(task_runner_, TaskRunnerHandle::GetSingleThreaded()); |
| 73 EXPECT_TRUE(SequencedTaskRunnerHandle::IsSet()); | 72 EXPECT_EQ(task_runner_, TaskRunnerHandle::GetSequenced()); |
| 74 EXPECT_EQ(task_runner_, ThreadTaskRunnerHandle::Get()); | |
| 75 EXPECT_EQ(task_runner_, SequencedTaskRunnerHandle::Get()); | |
| 76 break; | 73 break; |
| 77 } | 74 } |
| 78 | 75 |
| 79 { | 76 { |
| 80 AutoLock auto_lock(lock_); | 77 AutoLock auto_lock(lock_); |
| 81 | 78 |
| 82 DCHECK_LE(task_index, num_posted_tasks_); | 79 DCHECK_LE(task_index, num_posted_tasks_); |
| 83 | 80 |
| 84 if ((execution_mode_ == ExecutionMode::SINGLE_THREADED || | 81 if ((execution_mode_ == ExecutionMode::SINGLE_THREADED || |
| 85 execution_mode_ == ExecutionMode::SEQUENCED) && | 82 execution_mode_ == ExecutionMode::SEQUENCED) && |
| (...skipping 11 matching lines...) Expand all Loading... |
| 97 cv_.Signal(); | 94 cv_.Signal(); |
| 98 } | 95 } |
| 99 | 96 |
| 100 if (!after_task_closure.is_null()) | 97 if (!after_task_closure.is_null()) |
| 101 after_task_closure.Run(); | 98 after_task_closure.Run(); |
| 102 } | 99 } |
| 103 | 100 |
| 104 } // namespace test | 101 } // namespace test |
| 105 } // namespace internal | 102 } // namespace internal |
| 106 } // namespace base | 103 } // namespace base |
| OLD | NEW |