Virtualize The Existence of a Scheduler Worker Thread

base/task_scheduler/scheduler_thread_pool_impl.cc

Index: base/task_scheduler/scheduler_thread_pool_impl.cc
diff --git a/base/task_scheduler/scheduler_thread_pool_impl.cc b/base/task_scheduler/scheduler_thread_pool_impl.cc
index c7e339a0dd68855a238f7260358449dc75571b28..1aaa8bbf42da651a3081803fb1b71eb8384009a1 100644
--- a/base/task_scheduler/scheduler_thread_pool_impl.cc
+++ b/base/task_scheduler/scheduler_thread_pool_impl.cc
@@ -203,6 +203,7 @@ class SchedulerThreadPoolImpl::SchedulerWorkerThreadDelegateImpl
       SchedulerWorkerThread* worker_thread) override;
   void ReEnqueueSequence(scoped_refptr<Sequence> sequence) override;
   TimeDelta GetSleepTimeout() override;
+  bool CanDetach(SchedulerWorkerThread* worker_thread) override;
 
  private:
   SchedulerThreadPoolImpl* outer_;
@@ -485,6 +486,11 @@ TimeDelta SchedulerThreadPoolImpl::SchedulerWorkerThreadDelegateImpl::
   return TimeDelta::Max();
 }
 
+bool SchedulerThreadPoolImpl::SchedulerWorkerThreadDelegateImpl::CanDetach(
+    SchedulerWorkerThread* worker_thread) {
+  return false;
+}
+
 SchedulerThreadPoolImpl::SchedulerThreadPoolImpl(
     StringPiece name,
     IORestriction io_restriction,
@@ -521,7 +527,8 @@ bool SchedulerThreadPoolImpl::Initialize(
             thread_priority, WrapUnique(new SchedulerWorkerThreadDelegateImpl(
                                  this, re_enqueue_sequence_callback,
                                  &shared_priority_queue_, static_cast<int>(i))),
-            task_tracker_);
+            task_tracker_,
+            SchedulerWorkerThread::InitialWorkerState::ALIVE);
     if (!worker_thread)
       break;
     idle_worker_threads_stack_.Push(worker_thread.get());