Index: base/threading/sequenced_worker_pool_unittest.cc |
diff --git a/base/threading/sequenced_worker_pool_unittest.cc b/base/threading/sequenced_worker_pool_unittest.cc |
index a7e9e93f86a0b6553b501cabcc80520f3411e332..397cf4da32b4f42e90eb48abc00892443da6d4bf 100644 |
--- a/base/threading/sequenced_worker_pool_unittest.cc |
+++ b/base/threading/sequenced_worker_pool_unittest.cc |
@@ -8,6 +8,7 @@ |
#include "base/memory/ref_counted.h" |
#include "base/synchronization/condition_variable.h" |
#include "base/synchronization/lock.h" |
+#include "base/task_runner_test_template.h" |
#include "base/threading/platform_thread.h" |
#include "base/threading/sequenced_worker_pool.h" |
#include "base/tracked_objects.h" |
@@ -223,8 +224,6 @@ void EnsureTasksToCompleteCountAndUnblock(scoped_refptr<TestTracker> tracker, |
blocker->Unblock(threads_to_awake); |
} |
-} // namespace |
- |
// Tests that same-named tokens have the same ID. |
TEST_F(SequencedWorkerPoolTest, NamedTokens) { |
const std::string name1("hello"); |
@@ -403,4 +402,40 @@ TEST_F(SequencedWorkerPoolTest, ContinueOnShutdown) { |
EXPECT_EQ(1u, result.size()); |
} |
+class SequencedWorkerPoolTaskRunnerTestDelegate { |
+ public: |
+ SequencedWorkerPoolTaskRunnerTestDelegate() {} |
+ |
+ ~SequencedWorkerPoolTaskRunnerTestDelegate() {} |
+ |
+ void StartTaskRunner() { |
+ worker_pool_ = |
+ new SequencedWorkerPool(10, "SequencedWorkerPoolTaskRunnerTest"); |
+ } |
+ |
+ scoped_refptr<SequencedWorkerPool> GetTaskRunner() { |
+ return worker_pool_; |
+ } |
+ |
+ void StopTaskRunner() { |
+ worker_pool_->Shutdown(); |
+ worker_pool_ = NULL; |
+ } |
+ |
+ bool TaskRunnerHandlesNonZeroDelays() const { |
+ // TODO(akalin): Set this to true once we SequencedWorkerPool |
Nico
2012/02/29 01:26:55
s/we //
akalin
2012/02/29 01:32:48
Done.
|
+ // handles non-zero delays. |
+ return false; |
+ } |
+ |
+ private: |
+ scoped_refptr<SequencedWorkerPool> worker_pool_; |
+}; |
+ |
+INSTANTIATE_TYPED_TEST_CASE_P( |
+ SequencedWorkerPool, TaskRunnerTest, |
+ SequencedWorkerPoolTaskRunnerTestDelegate); |
+ |
+} // namespace |
+ |
} // namespace base |