TaskScheduler: Delegate instead of callbacks for SchedulerWorkerThread.

base/task_scheduler/scheduler_worker_thread.h

Index: base/task_scheduler/scheduler_worker_thread.h
diff --git a/base/task_scheduler/scheduler_worker_thread.h b/base/task_scheduler/scheduler_worker_thread.h
index 8b129a3d5f20d38b8729f6df1ff49743378fab4f..f11c661311bccd79e536fb1fb336c8e640a94b95 100644
--- a/base/task_scheduler/scheduler_worker_thread.h
+++ b/base/task_scheduler/scheduler_worker_thread.h
@@ -8,7 +8,6 @@
 #include <memory>
 
 #include "base/base_export.h"
-#include "base/callback.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/synchronization/waitable_event.h"
@@ -19,42 +18,29 @@
 namespace base {
 namespace internal {
 
+class SchedulerWorkerThreadDelegate;
 class TaskTracker;
 
-// A thread that runs Tasks from Sequences returned by a callback.
+// A thread that runs Tasks from Sequences returned by a delegate.
 //
 // A SchedulerWorkerThread is woken up when its WakeUp() method is called. After
-// a wake- up, a SchedulerWorkerThread runs Tasks from Sequences returned by its
-// "get work" callback as long as it doesn't return nullptr. It also
-// periodically checks with its TaskTracker whether shutdown has completed and
-// exits when it has.
+// a wake-up, a SchedulerWorkerThread runs Tasks from Sequences returned by the
+// GetWork() method of its delegate as long as it doesn't return nullptr. It
+// also periodically checks with its TaskTracker whether shutdown has completed
+// and exits when it has.
 //
 // This class is thread-safe.
 class BASE_EXPORT SchedulerWorkerThread : public PlatformThread::Delegate {
  public:
-  // Callback invoked to get a Sequence from which to run a Task on
-  // |worker_thread|.
-  using GetWorkCallback =
-      Callback<scoped_refptr<Sequence>(SchedulerWorkerThread* worker_thread)>;
-
-  // Callback invoked after |worker_thread| has tried to run a Task from
-  // |sequence| (a TaskTracker might have prevented the Task from running).
-  using RanTaskFromSequenceCallback =
-      Callback<void(const SchedulerWorkerThread* worker_thread,
-                    scoped_refptr<Sequence> sequence)>;
-
   // Creates a SchedulerWorkerThread with priority |thread_priority| that runs
-  // Tasks from Sequences returned by |get_work_callback|. |main_entry_callback|
-  // is invoked when the main function of the SchedulerWorkerThread is entered.
-  // |ran_task_from_sequence_callback| is invoked after the
-  // SchedulerWorkerThread has tried to run a Task from a Sequence returned by
-  // |get_work_callback|. |task_tracker| is used to handle shutdown behavior of
-  // Tasks. Returns nullptr if creating the underlying platform thread fails.
+  // Tasks from Sequences returned by the GetWork() method of |delegate|.
+  // |delegate| is also notified when the thread's main function enters/exits

[robliao, 2016/04/06 21:28:20]

The |delegate| specific behavior can be removed here and any important details
should probably be on SchedulerWorkerThreadDelegate itself.

[fdoray, 2016/04/07 13:53:41]

Done.

+  // and after the thread has tried to run a Task. |task_tracker| is used to
+  // handle shutdown behavior of Tasks. Returns nullptr if creating the
+  // underlying platform thread fails.
   static std::unique_ptr<SchedulerWorkerThread> CreateSchedulerWorkerThread(
       ThreadPriority thread_priority,
-      const Closure& main_entry_callback,
-      const GetWorkCallback& get_work_callback,
-      const RanTaskFromSequenceCallback& ran_task_from_sequence_callback,
+      SchedulerWorkerThreadDelegate* delegate,
       TaskTracker* task_tracker);
 
   // Destroying a SchedulerWorkerThread in production is not allowed; it is
@@ -63,8 +49,8 @@ class BASE_EXPORT SchedulerWorkerThread : public PlatformThread::Delegate {
   ~SchedulerWorkerThread() override;
 
   // Wakes up this SchedulerWorkerThread. After this is called, this
-  // SchedulerWorkerThread will run Tasks from Sequences returned by
-  // |get_work_callback_| until it returns nullptr.
+  // SchedulerWorkerThread will run Tasks from Sequences returned by the
+  // GetWork() method of its delegate until it returns nullptr.
   void WakeUp();
 
   // Joins this SchedulerWorkerThread. If a Task is already running, it will be
@@ -72,12 +58,9 @@ class BASE_EXPORT SchedulerWorkerThread : public PlatformThread::Delegate {
   void JoinForTesting();
 
  private:
-  SchedulerWorkerThread(
-      ThreadPriority thread_priority,
-      const Closure& main_entry_callback,
-      const GetWorkCallback& get_work_callback,
-      const RanTaskFromSequenceCallback& ran_task_from_sequence_callback,
-      TaskTracker* task_tracker);
+  SchedulerWorkerThread(ThreadPriority thread_priority,
+                        SchedulerWorkerThreadDelegate* delegate,
+                        TaskTracker* task_tracker);
 
   // PlatformThread::Delegate:
   void ThreadMain() override;
@@ -90,9 +73,7 @@ class BASE_EXPORT SchedulerWorkerThread : public PlatformThread::Delegate {
   // Event signaled to wake up this SchedulerWorkerThread.
   WaitableEvent wake_up_event_;
 
-  const Closure main_entry_callback_;
-  const GetWorkCallback get_work_callback_;
-  const RanTaskFromSequenceCallback ran_task_from_sequence_callback_;
+  SchedulerWorkerThreadDelegate* const delegate_;
   TaskTracker* const task_tracker_;
 
   // Synchronizes access to |should_exit_for_testing_|.