[scheduler] Implement time-based cpu throttling.

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

 // 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.
 
 #include "platform/scheduler/base/time_domain.h"
 
 #include <set>
 
 #include "platform/scheduler/base/task_queue_impl.h"
 #include "platform/scheduler/base/task_queue_manager_delegate.h"
@@ skipping 63 matching lines @@
                                      base::TimeTicks now) {
   DCHECK(main_thread_checker_.CalledOnValidThread());
   if (delayed_wakeup_multimap_.empty() ||
       delayed_run_time < delayed_wakeup_multimap_.begin()->first) {
     base::TimeDelta delay = std::max(base::TimeDelta(), delayed_run_time - now);
     RequestWakeup(now, delay);
   }
 
   delayed_wakeup_multimap_.insert(std::make_pair(delayed_run_time, queue));
   if (observer_)
-    observer_->OnTimeDomainHasDelayedWork();
+    observer_->OnTimeDomainHasDelayedWork(queue);
 }
 
 void TimeDomain::CancelDelayedWork(internal::TaskQueueImpl* queue,
                                    base::TimeTicks delayed_run_time) {
   DCHECK(main_thread_checker_.CalledOnValidThread());
 
   auto iterpair = delayed_wakeup_multimap_.equal_range(delayed_run_time);
   for (auto it = iterpair.first; it != iterpair.second; ++it) {
     if (it->second == queue) {
       base::TimeTicks prev_first_wakeup =
@@ skipping 25 matching lines @@
     }
   }
 }
 
 void TimeDomain::RegisterAsUpdatableTaskQueue(internal::TaskQueueImpl* queue) {
   {
     base::AutoLock lock(newly_updatable_lock_);
     newly_updatable_.push_back(queue);
   }
   if (observer_)
-    observer_->OnTimeDomainHasImmediateWork();
+    observer_->OnTimeDomainHasImmediateWork(queue);
 }
 
 bool TimeDomain::UnregisterAsUpdatableTaskQueue(
     internal::TaskQueueImpl* queue) {
   DCHECK(main_thread_checker_.CalledOnValidThread());
 
   bool was_updatable = updatable_queue_set_.erase(queue) != 0;
 
   base::AutoLock lock(newly_updatable_lock_);
   // Remove all copies of |queue| from |newly_updatable_|.
@@ skipping 104 matching lines @@
   if (!delayed_wakeup_multimap_.empty()) {
     base::TimeDelta delay = delayed_wakeup_multimap_.begin()->first - Now();
     state->SetDouble("next_delay_ms", delay.InMillisecondsF());
   }
   AsValueIntoInternal(state);
   state->EndDictionary();
 }
 
 }  // namespace scheduler
 }  // namespace blink