Worker: Introduce per-global-scope task scheduler

third_party/WebKit/Source/core/workers/WorkerOrWorkletGlobalScope.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/WorkerOrWorkletGlobalScope.h"
 
 #include "core/dom/ExecutionContextTask.h"
+#include "core/dom/TaskRunnerHelper.h"
 #include "core/frame/Deprecation.h"
 #include "core/inspector/ConsoleMessage.h"
 #include "core/probe/CoreProbes.h"
 #include "core/workers/WorkerReportingProxy.h"
 #include "core/workers/WorkerThread.h"
 #include "platform/CrossThreadFunctional.h"
 #include "wtf/Functional.h"
 
 namespace blink {
 
@@ skipping 12 matching lines @@
   if (m_deprecationWarningBits.quickGet(feature))
     return;
   m_deprecationWarningBits.quickSet(feature);
   DCHECK(!Deprecation::deprecationMessage(feature).isEmpty());
   addConsoleMessage(
       ConsoleMessage::create(DeprecationMessageSource, WarningMessageLevel,
                              Deprecation::deprecationMessage(feature)));
 }
 
 void WorkerOrWorkletGlobalScope::postTask(
-    TaskType,
+    TaskType type,
     const WebTraceLocation& location,
     std::unique_ptr<ExecutionContextTask> task,
     const String& taskNameForInstrumentation) {
   if (!thread())
     return;
 
   bool isInstrumented = !taskNameForInstrumentation.isEmpty();
   if (isInstrumented) {
     probe::asyncTaskScheduled(this, "Worker task", task.get());
   }
 
-  thread()->postTask(
-      location, crossThreadBind(&WorkerOrWorkletGlobalScope::runTask,
-                                wrapCrossThreadWeakPersistent(this),
-                                WTF::passed(std::move(task)), isInstrumented));
+  TaskRunnerHelper::get(type, this)
+      ->postTask(location,
+                 crossThreadBind(&WorkerOrWorkletGlobalScope::runTask,
+                                 wrapCrossThreadWeakPersistent(this),
+                                 WTF::passed(std::move(task)), isInstrumented));
 }
 
 void WorkerOrWorkletGlobalScope::runTask(
     std::unique_ptr<ExecutionContextTask> task,
     bool isInstrumented) {
   DCHECK(thread()->isCurrentThread());
   probe::AsyncTask asyncTask(this, task.get(), nullptr, isInstrumented);
   task->performTask(this);
 }
 
 }  // namespace blink