Implementation of SequencedTaskRunner based on SequencedWorkerPool.

base/sequenced_task_runner_impl_unittest.cc

+// Copyright (c) 2012 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "testing/gtest/include/gtest/gtest.h"
+
+#include "base/message_loop.h"
+#include "base/sequenced_task_runner_impl.h"
+#include "base/test/task_runner_test_template.h"
+#include "base/test/sequenced_task_runner_test_template.h"
+#include "base/threading/sequenced_worker_pool_unittest.h"
+
+namespace base {
+
+class SequencedTaskRunnerImplTestDelegate {
+ public:
+  SequencedTaskRunnerImplTestDelegate() {}
+
+  ~SequencedTaskRunnerImplTestDelegate() {}
+
+  void StartTaskRunner() {
+    pool_owner_.reset(
+        new SequencedWorkerPoolOwner(10, "SequencedTaskRunnerImplTest"));
+    task_runner_ = new SequencedTaskRunnerImpl(pool_owner_->pool());
+  }
+
+  scoped_refptr<SequencedTaskRunner> GetTaskRunner() {
+    return task_runner_;
+  }
+
+  void StopTaskRunner() {
+    pool_owner_->pool()->FlushForTesting();
+    pool_owner_->pool()->Shutdown();
+    // Don't reset |pool_owner_| here, as the test may still hold a
+    // reference to the pool.
+  }
+
+  bool TaskRunnerHandlesNonZeroDelays() const {
+    // TODO(akalin): Set this to true once SequencedWorkerPool handles
+    // non-zero delays.
+    return false;
+  }
+
+ private:
+  MessageLoop message_loop_;
+  scoped_ptr<SequencedWorkerPoolOwner> pool_owner_;
+  scoped_refptr<SequencedTaskRunnerImpl> task_runner_;
+};
+
+INSTANTIATE_TYPED_TEST_CASE_P(
+    SequencedTaskRunnerImpl, TaskRunnerTest,
+    SequencedTaskRunnerImplTestDelegate);
+
+INSTANTIATE_TYPED_TEST_CASE_P(
+    SequencedTaskRunnerImpl, SequencedTaskRunnerTest,
+    SequencedTaskRunnerImplTestDelegate);
+
+}  // namespace base