Speculative patch: Make it safe to delete the TQM inside a Task

content/child/scheduler/task_queue_manager.h

 // Copyright 2014 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.
 
 #ifndef CONTENT_RENDERER_SCHEDULER_TASK_QUEUE_MANAGER_H_
 #define CONTENT_RENDERER_SCHEDULER_TASK_QUEUE_MANAGER_H_
 
 #include "base/atomic_sequence_num.h"
 #include "base/debug/task_annotator.h"
 #include "base/macros.h"
@@ skipping 110 matching lines @@
   // manager executes its tasks on.
   void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer);
   void RemoveTaskObserver(base::MessageLoop::TaskObserver* task_observer);
 
   void SetTimeSourceForTesting(scoped_refptr<cc::TestNowSource> time_source);
 
  private:
   friend class internal::LazyNow;
   friend class internal::TaskQueue;
 
+  class DeletionSentinel : public base::RefCounted<DeletionSentinel> {
+   private:
+    friend class base::RefCounted<DeletionSentinel>;
+    ~DeletionSentinel() {}
+  };
+
   // Called by the task queue to register a new pending task and allocate a
   // sequence number for it.
   void DidQueueTask(base::PendingTask* pending_task);
 
   // Post a task to call DoWork() on the main task runner.  Only one pending
   // DoWork is allowed from the main thread, to prevent an explosion of pending
   // DoWorks.
   void MaybePostDoWorkOnMainRunner();
 
   // Use the selector to choose a pending task and run it.
@@ skipping 10 matching lines @@
 
   // Chooses the next work queue to service. Returns true if |out_queue_index|
   // indicates the queue from which the next task should be run, false to
   // avoid running any tasks.
   bool SelectWorkQueueToService(size_t* out_queue_index);
 
   // Runs a single nestable task from the work queue designated by
   // |queue_index|. If |has_previous_task| is true, |previous_task| should
   // contain the previous task in this work batch. Non-nestable task are
   // reposted on the run loop. The queue must not be empty.
-  void ProcessTaskFromWorkQueue(size_t queue_index,
+  // Returns true if the TaskQueueManager got deleted, and false otherwise.
+  bool ProcessTaskFromWorkQueue(size_t queue_index,
                                 bool has_previous_task,
                                 base::PendingTask* previous_task);
 
   bool RunsTasksOnCurrentThread() const;
   bool PostDelayedTask(const tracked_objects::Location& from_here,
                        const base::Closure& task,
                        base::TimeDelta delay);
   bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here,
                                   const base::Closure& task,
                                   base::TimeDelta delay);
@@ skipping 19 matching lines @@
   int pending_dowork_count_;
 
   int work_batch_size_;
 
   scoped_refptr<cc::TestNowSource> time_source_;
 
   ObserverList<base::MessageLoop::TaskObserver> task_observers_;
 
   const char* disabled_by_default_tracing_category_;
 
+  scoped_refptr<DeletionSentinel> deletion_sentinel_;
   base::WeakPtrFactory<TaskQueueManager> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(TaskQueueManager);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_RENDERER_SCHEDULER_TASK_QUEUE_MANAGER_H_