Virtualize The Existence of a Scheduler Worker Thread

base/task_scheduler/scheduler_worker_thread_stack_unittest.cc

 // Copyright 2016 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 "base/task_scheduler/scheduler_worker_thread_stack.h"
 
 #include "base/logging.h"
 #include "base/memory/ptr_util.h"
 #include "base/memory/ref_counted.h"
 #include "base/task_scheduler/scheduler_worker_thread.h"
@@ skipping 14 matching lines @@
  public:
   void OnMainEntry(SchedulerWorkerThread* worker_thread) override {}
   scoped_refptr<Sequence> GetWork(
       SchedulerWorkerThread* worker_thread) override {
     return nullptr;
   }
   void ReEnqueueSequence(scoped_refptr<Sequence> sequence) override {
     ADD_FAILURE() << "This delegate not expect to have sequences to reenqueue.";
   }
   TimeDelta GetSleepTimeout() override {
-    ADD_FAILURE() <<
-        "The mock thread is not expected to be woken before it is shutdown";
     return TimeDelta::Max();
   }
+  bool CanDetach(SchedulerWorkerThread* worker_thread) override {
+    return false;
+  }
 };
 
 class TaskSchedulerWorkerThreadStackTest : public testing::Test {
  protected:
   void SetUp() override {
     thread_a_ = SchedulerWorkerThread::Create(
         ThreadPriority::NORMAL,
-        WrapUnique(new MockSchedulerWorkerThreadDelegate), &task_tracker_);
+        WrapUnique(new MockSchedulerWorkerThreadDelegate), &task_tracker_,
+        SchedulerWorkerThread::InitialWorkerState::ALIVE);
     ASSERT_TRUE(thread_a_);
     thread_b_ = SchedulerWorkerThread::Create(
         ThreadPriority::NORMAL,
-        WrapUnique(new MockSchedulerWorkerThreadDelegate), &task_tracker_);
+        WrapUnique(new MockSchedulerWorkerThreadDelegate), &task_tracker_,
+        SchedulerWorkerThread::InitialWorkerState::ALIVE);
     ASSERT_TRUE(thread_b_);
     thread_c_ = SchedulerWorkerThread::Create(
         ThreadPriority::NORMAL,
-        WrapUnique(new MockSchedulerWorkerThreadDelegate), &task_tracker_);
+        WrapUnique(new MockSchedulerWorkerThreadDelegate), &task_tracker_,
+        SchedulerWorkerThread::InitialWorkerState::ALIVE);
     ASSERT_TRUE(thread_c_);
   }
 
   void TearDown() override {
     thread_a_->JoinForTesting();
     thread_b_->JoinForTesting();
     thread_c_->JoinForTesting();
   }
 
   std::unique_ptr<SchedulerWorkerThread> thread_a_;
@@ skipping 97 matching lines @@
 
 // Verify that Push() DCHECKs when a value is inserted twice.
 TEST_F(TaskSchedulerWorkerThreadStackTest, PushTwice) {
   SchedulerWorkerThreadStack stack;
   stack.Push(thread_a_.get());
   EXPECT_DCHECK_DEATH({ stack.Push(thread_a_.get()); }, "");
 }
 
 }  // namespace internal
 }  // namespace base