Make tasks cancellable inside the blink scheduler.

third_party/WebKit/Source/platform/scheduler/base/time_domain.h

 // Copyright 2015 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 THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TIME_DOMAIN_H_
 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TIME_DOMAIN_H_
 
 #include <map>
 
 #include "base/callback.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/weak_ptr.h"
 #include "base/time/time.h"
 #include "platform/scheduler/base/lazy_now.h"
 #include "platform/scheduler/base/task_queue_impl.h"
 
 namespace blink {
 namespace scheduler {
 namespace internal {
 class TaskQueueImpl;
 }  // internal
 class TaskQueueManager;
 class TaskQueueManagerDelegate;
 
+// The TimeDomain's job is to keep track of moments when delayed tasks have been
+// scheduled to fire and to notify their TaskQueues via UpdateDelayedWorkQueue.
+//
+// The time domain keeps track of the next wakeup required to pump delayed tasks
+// and issues |RequestWakeup| calls to the subclass as needed.  Where possible
+// it tried to de-dupe these wakeups. Ideally it would be possible to cancel
+// them, but that's not currently supported by the base message loop.
+//
+// The clock itself is provided by subclasses of the TimeDomain and it may be
+// the real wall clock or a synthetic (virtual) time base.
 class BLINK_PLATFORM_EXPORT TimeDomain {
  public:
   class BLINK_PLATFORM_EXPORT Observer {
    public:
     virtual ~Observer() {}
 
     // Called when an empty TaskQueue registered with this TimeDomain has a task
     // enqueued.
     virtual void OnTimeDomainHasImmediateWork() = 0;
 
@@ skipping 41 matching lines @@
   // Adds |queue| to the set of task queues that UpdateWorkQueues calls
   // UpdateWorkQueue on.
   void RegisterAsUpdatableTaskQueue(internal::TaskQueueImpl* queue);
 
   // Schedules a call to TaskQueueImpl::MoveReadyDelayedTasksToDelayedWorkQueue
   // when this TimeDomain reaches |delayed_run_time|.
   void ScheduleDelayedWork(internal::TaskQueueImpl* queue,
                            base::TimeTicks delayed_run_time,
                            base::TimeTicks now);
 
+  // Cancels a call to TaskQueueImpl::MoveReadyDelayedTasksToDelayedWorkQueue
+  // previously requested with ScheduleDelayedWork.  Note this only works if
+  // delayed_run_time is _not_ the next scheduled run time.
+  void CancelDelayedWork(internal::TaskQueueImpl* queue,
+                         base::TimeTicks delayed_run_time);
+
   // Registers the |queue|.
   void RegisterQueue(internal::TaskQueueImpl* queue);
 
   // Removes |queue| from the set of task queues that UpdateWorkQueues calls
   // UpdateWorkQueue on. Returns true if |queue| was updatable.
   bool UnregisterAsUpdatableTaskQueue(internal::TaskQueueImpl* queue);
 
   // Removes |queue| from all internal data structures.
   void UnregisterQueue(internal::TaskQueueImpl* queue);
 
@@ skipping 51 matching lines @@
 
   base::ThreadChecker main_thread_checker_;
 
   DISALLOW_COPY_AND_ASSIGN(TimeDomain);
 };
 
 }  // namespace scheduler
 }  // namespace blink
 
 #endif  // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TIME_DOMAIN_H_