Introduce SchedulerSingleThreadTaskRunnerManager

base/task_scheduler/scheduler_worker.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.h"
 
 #include <stddef.h>
 
 #include <utility>
 
@@ skipping 49 matching lines @@
 
       UpdateThreadPriority(GetDesiredThreadPriority());
 
       // Get the sequence containing the next task to execute.
       scoped_refptr<Sequence> sequence =
           outer_->delegate_->GetWork(outer_.get());
       if (!sequence) {
         if (outer_->delegate_->CanDetach(outer_.get())) {
           detached_thread = outer_->DetachThreadObject(DetachNotify::DELEGATE);
           if (detached_thread) {
-            outer_ = nullptr;
             DCHECK_EQ(detached_thread.get(), this);
             PlatformThread::Detach(thread_handle_);
             break;
           }
         }
         WaitForWork();
         continue;
       }
 
       if (outer_->task_tracker_->RunTask(sequence->TakeTask(),
@@ skipping 31 matching lines @@
     // We arrive here in the following cases:
     // Thread Detachment Request:
     //   * |detached_thread| will not be nullptr.
     // ShouldExit() returns true:
     //   * Shutdown: DetachThreadObject() returns the thread object.
     //   * Cleanup: DetachThreadObject() returns the thread object.
     //   * Join: DetachThreadObject() could return either the thread object or
     //           nullptr. JoinForTesting() cleans up if we get nullptr.
     if (!detached_thread)
       detached_thread = outer_->DetachThreadObject(DetachNotify::SILENT);
+
+    outer_->delegate_->OnMainExit();
   }
 
   void Join() { PlatformThread::Join(thread_handle_); }
 
   void WakeUp() { wake_up_event_.Signal(); }
 
   bool IsWakeUpPending() { return wake_up_event_.IsSignaled(); }
 
  private:
   Thread(scoped_refptr<SchedulerWorker> outer)
@@ skipping 197 matching lines @@
   CreateThread();
 }
 
 bool SchedulerWorker::ShouldExit() {
   return task_tracker_->IsShutdownComplete() ||
          join_called_for_testing_.IsSet() || should_exit_.IsSet();
 }
 
 }  // namespace internal
 }  // namespace base