Add a WorkerScheduler and a WebThreadImplForWorker

content/child/scheduler/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 "content/child/scheduler/worker_scheduler_impl.h"
+
+#include "base/bind.h"
+#include "base/message_loop/message_loop_proxy.h"
+#include "base/trace_event/trace_event.h"
+#include "base/trace_event/trace_event_argument.h"
+#include "content/child/scheduler/nestable_single_thread_task_runner.h"
+
+namespace content {
+
+WorkerSchedulerImpl::WorkerSchedulerImpl(
+    scoped_refptr<NestableSingleThreadTaskRunner> main_task_runner)
+    : helper_(main_task_runner,
+              this,
+              "worker.scheduler",
+              TRACE_DISABLED_BY_DEFAULT("worker.scheduler"),
+              SchedulerHelper::TASK_QUEUE_COUNT),
+      initalized_(false) {
+  TRACE_EVENT_OBJECT_CREATED_WITH_ID(
+      TRACE_DISABLED_BY_DEFAULT("worker.scheduler"), "WorkerScheduler", this);
+}
+
+WorkerSchedulerImpl::~WorkerSchedulerImpl() {
+  TRACE_EVENT_OBJECT_DELETED_WITH_ID(
+      TRACE_DISABLED_BY_DEFAULT("worker.scheduler"), "WorkerScheduler", this);
+}
+
+void WorkerSchedulerImpl::Init() {
+  initalized_ = true;
+  helper_.InitiateLongIdlePeriod();
+}
+
+scoped_refptr<base::SingleThreadTaskRunner>
+WorkerSchedulerImpl::DefaultTaskRunner() {
+  DCHECK(initalized_);
+  return helper_.DefaultTaskRunner();
+}
+
+scoped_refptr<SingleThreadIdleTaskRunner>
+WorkerSchedulerImpl::IdleTaskRunner() {
+  DCHECK(initalized_);
+  return helper_.IdleTaskRunner();
+}
+
+bool WorkerSchedulerImpl::CanExceedIdleDeadlineIfRequired() const {
+  DCHECK(initalized_);
+  return helper_.CanExceedIdleDeadlineIfRequired();
+}
+
+void WorkerSchedulerImpl::AddTaskObserver(
+    base::MessageLoop::TaskObserver* task_observer) {
+  DCHECK(initalized_);
+  helper_.AddTaskObserver(task_observer);
+}
+
+void WorkerSchedulerImpl::RemoveTaskObserver(
+    base::MessageLoop::TaskObserver* task_observer) {
+  DCHECK(initalized_);
+  helper_.RemoveTaskObserver(task_observer);
+}
+
+void WorkerSchedulerImpl::Shutdown() {
+  DCHECK(initalized_);
+  helper_.Shutdown();
+}
+
+void WorkerSchedulerImpl::SetTimeSourceForTesting(
+    scoped_refptr<cc::TestNowSource> time_source) {
+  helper_.SetTimeSourceForTesting(time_source);
+}
+
+void WorkerSchedulerImpl::SetWorkBatchSizeForTesting(size_t work_batch_size) {
+  helper_.SetWorkBatchSizeForTesting(work_batch_size);
+}
+
+bool WorkerSchedulerImpl::CanEnterLongIdlePeriod(base::TimeTicks,
+                                                 base::TimeDelta*) {
+  return true;
+}
+
+base::TimeTicks WorkerSchedulerImpl::CurrentIdleTaskDeadlineForTesting() const {
+  base::TimeTicks deadline;
+  helper_.CurrentIdleTaskDeadlineCallback(&deadline);
+  return deadline;
+}
+
+}  // namespace content