Worker: Introduce per-global-scope task scheduler

third_party/WebKit/Source/core/workers/ThreadedMessagingProxyBase.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/ThreadedMessagingProxyBase.h"
 
 #include "bindings/core/v8/SourceLocation.h"
 #include "core/dom/Document.h"
 #include "core/frame/Deprecation.h"
 #include "core/loader/DocumentLoader.h"
 #include "core/loader/ThreadableLoadingContext.h"
 #include "core/workers/WorkerInspectorProxy.h"
+#include "core/workers/WorkerTaskRunners.h"
 #include "core/workers/WorkerThreadStartupData.h"
 #include "platform/wtf/CurrentTime.h"
 
 namespace blink {
 
 namespace {
 
 static int g_live_messaging_proxy_count = 0;
 
 }  // namespace
@@ skipping 43 matching lines @@
   WorkerThreadCreated();
 }
 
 void ThreadedMessagingProxyBase::PostTaskToWorkerGlobalScope(
     const WebTraceLocation& location,
     std::unique_ptr<WTF::CrossThreadClosure> task) {
   if (asked_to_terminate_)
     return;
 
   DCHECK(worker_thread_);
-  worker_thread_->PostTask(location, std::move(task));
+  worker_thread_->GetWorkerTaskRunners()
+      ->Get(TaskType::kNetworking)
+      ->PostTask(location, std::move(task));
 }
 
 void ThreadedMessagingProxyBase::PostTaskToLoader(
     const WebTraceLocation& location,
     std::unique_ptr<WTF::CrossThreadClosure> task) {
   parent_frame_task_runners_->Get(TaskType::kNetworking)
       ->PostTask(BLINK_FROM_HERE, std::move(task));
 }
 
 ThreadableLoadingContext*
@@ skipping 89 matching lines @@
 }
 
 bool ThreadedMessagingProxyBase::IsParentContextThread() const {
   // TODO(nhiroki): Nested worker is not supported yet, so the parent context
   // thread should be equal to the main thread (http://crbug.com/31666).
   DCHECK(execution_context_->IsDocument());
   return IsMainThread();
 }
 
 }  // namespace blink