Worker: Introduce per-global-scope task scheduler

third_party/WebKit/Source/core/workers/WorkerBackingThread.cpp

 // Copyright 2016 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 "core/workers/WorkerBackingThread.h"
 
 #include <memory>
 #include "bindings/core/v8/V8Binding.h"
 #include "bindings/core/v8/V8GCController.h"
 #include "bindings/core/v8/V8IdleTaskRunner.h"
 #include "bindings/core/v8/V8Initializer.h"
 #include "bindings/core/v8/V8PerIsolateData.h"
 #include "core/inspector/WorkerThreadDebugger.h"
 #include "platform/CrossThreadFunctional.h"
 #include "platform/RuntimeEnabledFeatures.h"
 #include "platform/WebThreadSupportingGC.h"
+#include "platform/scheduler/child/webthread_impl_for_worker_scheduler.h"
+#include "platform/scheduler/child/worker_global_scope_scheduler.h"
 #include "platform/wtf/PtrUtil.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebTraceLocation.h"
 
 namespace blink {
 
 #define DEFINE_STATIC_LOCAL_WITH_LOCK(type, name, arguments) \
   ASSERT(IsolatesMutex().Locked());                          \
   static type& name = *new type arguments
 
@@ skipping 64 matching lines @@
     // This statement runs only in tests.
     V8GCController::CollectAllGarbageForTesting(isolate_);
   }
   backing_thread_->Shutdown();
 
   RemoveWorkerIsolate(isolate_);
   V8PerIsolateData::Destroy(isolate_);
   isolate_ = nullptr;
 }
 
+std::unique_ptr<scheduler::WorkerGlobalScopeScheduler>
+WorkerBackingThread::CreateGlobalScopeScheduler() {
+  scheduler::WebThreadImplForWorkerScheduler& web_thread_for_worker =
+      static_cast<scheduler::WebThreadImplForWorkerScheduler&>(
+          BackingThread().PlatformThread());
+  return WTF::MakeUnique<scheduler::WorkerGlobalScopeScheduler>(
+      web_thread_for_worker.GetWorkerScheduler());
+}
+
 // static
 void WorkerBackingThread::MemoryPressureNotificationToWorkerThreadIsolates(
     v8::MemoryPressureLevel level) {
   MutexLocker lock(IsolatesMutex());
   for (v8::Isolate* isolate : Isolates())
     isolate->MemoryPressureNotification(level);
 }
 
 // static
 void WorkerBackingThread::SetRAILModeOnWorkerThreadIsolates(
     v8::RAILMode rail_mode) {
   MutexLocker lock(IsolatesMutex());
   for (v8::Isolate* isolate : Isolates())
     isolate->SetRAILMode(rail_mode);
 }
 
 }  // namespace blink