Introduce SchedulerSingleThreadTaskRunnerManager

base/task_scheduler/task_scheduler_impl_unittest.cc

Index: base/task_scheduler/task_scheduler_impl_unittest.cc
diff --git a/base/task_scheduler/task_scheduler_impl_unittest.cc b/base/task_scheduler/task_scheduler_impl_unittest.cc
index 6aaf4af8753cd16976280e8c0af0f56cbaeb93e9..76f06d35b8a16ef05341ab45017f46eb7e6c05fc 100644
--- a/base/task_scheduler/task_scheduler_impl_unittest.cc
+++ b/base/task_scheduler/task_scheduler_impl_unittest.cc
@@ -322,5 +322,27 @@ TEST_F(TaskSchedulerImplTest, GetMaxConcurrentTasksWithTraitsDeprecated) {
           TaskTraits().WithPriority(TaskPriority::USER_BLOCKING).MayBlock()));
 }
 
+// Verify that the RunsTasksOnCurrentThread() method of a Sequenced TaskRunner
+// returns false when called from a task that isn't part of the sequence. Note:

[gab, 2017/02/21 21:39:50]

"Note:" ?

[robliao, 2017/02/22 01:04:19]

Removed. (It's no longer needed)

+TEST_F(TaskSchedulerImplTest, SequencedRunsTasksOnCurrentThread) {
+  auto task_runner =
+      scheduler_->CreateSingleThreadTaskRunnerWithTraits(TaskTraits());
+  auto sequenced_task_runner =
+      scheduler_->CreateSequencedTaskRunnerWithTraits(TaskTraits());
+
+  WaitableEvent task_ran(WaitableEvent::ResetPolicy::MANUAL,
+                         WaitableEvent::InitialState::NOT_SIGNALED);
+  task_runner->PostTask(
+      FROM_HERE,
+      Bind(
+          [](scoped_refptr<TaskRunner> sequenced_task_runner,
+             WaitableEvent* task_ran) {
+            EXPECT_FALSE(sequenced_task_runner->RunsTasksOnCurrentThread());
+            task_ran->Signal();
+          },
+          sequenced_task_runner, Unretained(&task_ran)));
+  task_ran.Wait();

[gab, 2017/02/21 21:39:50]

Also test the other way around?

And drop
TaskSchedulerSingleThreadTaskRunnerManagerTest.SequencedRunsTasksOnCurrentThread
because it's redundant?

[robliao, 2017/02/22 01:04:19]

Removed redundant test and added reverse.

+}
+
 }  // namespace internal
 }  // namespace base