Worker: Introduce per-global-scope task scheduler

third_party/WebKit/Source/platform/scheduler/child/worker_scheduler_impl.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 "platform/scheduler/child/worker_scheduler_impl.h"
 
 #include "base/bind.h"
 #include "base/metrics/histogram_macros.h"
 #include "base/trace_event/trace_event.h"
 #include "base/trace_event/trace_event_argument.h"
+#include "platform/Histogram.h"
 #include "platform/scheduler/base/time_converter.h"
 #include "platform/scheduler/child/scheduler_tqm_delegate.h"
 #include "public/platform/scheduler/base/task_queue.h"
 
 namespace blink {
 namespace scheduler {
 
 namespace {
 // Workers could be short-lived, set a shorter interval than
 // the renderer thread.
@@ skipping 92 matching lines @@
 
   // The lifetime could be radically different for different workers,
   // some workers could be short-lived (but last at least 1 sec in
   // Service Workers case) or could be around as long as the tab is open.
   UMA_HISTOGRAM_CUSTOM_TIMES(
       "WorkerThread.Runtime", delta, base::TimeDelta::FromSeconds(1),
       base::TimeDelta::FromDays(1), 50 /* bucket count */);
   helper_.Shutdown();
 }
 
+scoped_refptr<TaskQueue> WorkerSchedulerImpl::NewUnthrottledTaskRunner(
+    TaskQueue::QueueType queue_type) {
+  helper_.CheckOnValidThread();
+  scoped_refptr<TaskQueue> unthrottled_task_queue(
+      helper_.NewTaskQueue(TaskQueue::Spec(queue_type)
+                               .SetShouldMonitorQuiescence(true)
+                               .SetTimeDomain(nullptr)));
+  return unthrottled_task_queue;
+}
+
 SchedulerHelper* WorkerSchedulerImpl::GetSchedulerHelperForTesting() {
   return &helper_;
 }
 
 bool WorkerSchedulerImpl::CanEnterLongIdlePeriod(base::TimeTicks,
                                                  base::TimeDelta*) {
   return true;
 }
 
 base::TimeTicks WorkerSchedulerImpl::CurrentIdleTaskDeadlineForTesting() const {
   return idle_helper_.CurrentIdleTaskDeadline();
 }
 
 void WorkerSchedulerImpl::WillProcessTask(TaskQueue* task_queue,
                                           double start_time) {}
 
 void WorkerSchedulerImpl::DidProcessTask(TaskQueue* task_queue,
                                          double start_time,
                                          double end_time) {
+  DEFINE_THREAD_SAFE_STATIC_LOCAL(
+      CustomCountHistogram, task_time_counter,
+      new CustomCountHistogram("WorkerThread.Task.Time", 0, 10000000, 50));
+  task_time_counter.Count((end_time - start_time) *
+                          base::Time::kMicrosecondsPerSecond);
+
   base::TimeTicks start_time_ticks =
       MonotonicTimeInSecondsToTimeTicks(start_time);
   base::TimeTicks end_time_ticks = MonotonicTimeInSecondsToTimeTicks(end_time);
 
   load_tracker_.RecordTaskTime(start_time_ticks, end_time_ticks);
 }
 
 void WorkerSchedulerImpl::OnBeginNestedMessageLoop() {}
 
 }  // namespace scheduler
 }  // namespace blink