[Try # 3] Scheduler refactoring to virtually eliminate redundant DoWorks

cc/test/ordered_simple_task_runner.cc

 // 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.
 
 #include "cc/test/ordered_simple_task_runner.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <limits>
@@ skipping 110 matching lines @@
   TRACE_TASK("OrderedSimpleTaskRunner::PostNonNestableDelayedTask", pt);
   pending_tasks_.insert(pt);
   return true;
 }
 
 bool OrderedSimpleTaskRunner::RunsTasksOnCurrentThread() const {
   DCHECK(thread_checker_.CalledOnValidThread());
   return true;
 }
 
-size_t OrderedSimpleTaskRunner::NumPendingTasks() const {
+size_t OrderedSimpleTaskRunner::NumPendingTasks() {
+  RemovePendingCancelledTasks();
   return pending_tasks_.size();
 }
 
-bool OrderedSimpleTaskRunner::HasPendingTasks() const {
+bool OrderedSimpleTaskRunner::HasPendingTasks() {
+  RemovePendingCancelledTasks();
   return pending_tasks_.size() > 0;
 }
 
 base::TimeTicks OrderedSimpleTaskRunner::NextTaskTime() {
+  RemovePendingCancelledTasks();
+
   if (pending_tasks_.size() <= 0) {
     return AbsoluteMaxNow();
   }
 
   return pending_tasks_.begin()->GetTimeToRun();
 }
 
 base::TimeDelta OrderedSimpleTaskRunner::DelayToNextTaskTime() {
   DCHECK(thread_checker_.CalledOnValidThread());
+  RemovePendingCancelledTasks();
 
   if (pending_tasks_.size() <= 0) {
     return AbsoluteMaxNow() - base::TimeTicks();
   }
 
   base::TimeDelta delay = NextTaskTime() - now_src_->NowTicks();
   if (delay > base::TimeDelta())
     return delay;
   return base::TimeDelta();
 }
@@ skipping 32 matching lines @@
   modifiable_conditions.push_back(TaskRunCountBelow(max_tasks_));
 
   // If to advance now or not
   if (!advance_now_) {
     modifiable_conditions.push_back(NowBefore(now_src_->NowTicks()));
   } else {
     modifiable_conditions.push_back(AdvanceNow());
   }
 
   while (pending_tasks_.size() > 0) {
+    // Skip canceled tasks.
+    if (pending_tasks_.begin()->task.IsCancelled()) {
+      pending_tasks_.erase(pending_tasks_.begin());
+      continue;
+    }
     // Check if we should continue to run pending tasks.
     bool condition_success = true;
     for (std::vector<base::Callback<bool(void)>>::iterator it =
              modifiable_conditions.begin();
          it != modifiable_conditions.end();
          it++) {
       condition_success = it->Run();
       if (!condition_success)
         break;
     }
@@ skipping 126 matching lines @@
 }
 
 bool OrderedSimpleTaskRunner::AdvanceNowCallback() {
   base::TimeTicks next_task_time = NextTaskTime();
   if (now_src_->NowTicks() < next_task_time) {
     now_src_->Advance(next_task_time - now_src_->NowTicks());
   }
   return true;
 }
 
+void OrderedSimpleTaskRunner::RemovePendingCancelledTasks() {
+  // Remove canceled tasks.
+  while (!pending_tasks_.empty() &&
+         pending_tasks_.begin()->task.IsCancelled()) {
+    pending_tasks_.erase(pending_tasks_.begin());
+  }
+}
+
 }  // namespace cc