Reland of Worker: Introduce per-global-scope task scheduler

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

 /*
  * Copyright (C) 2008 Apple Inc. All Rights Reserved.
  * Copyright (C) 2009 Google Inc. All Rights Reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 12 matching lines @@
  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  *
  */
 
 #include "core/workers/InProcessWorkerMessagingProxy.h"
 
 #include <memory>
 #include "core/dom/Document.h"
 #include "core/dom/SecurityContext.h"
+#include "core/dom/TaskRunnerHelper.h"
 #include "core/events/ErrorEvent.h"
 #include "core/events/MessageEvent.h"
 #include "core/frame/LocalFrame.h"
 #include "core/frame/csp/ContentSecurityPolicy.h"
 #include "core/loader/DocumentLoadTiming.h"
 #include "core/loader/DocumentLoader.h"
 #include "core/origin_trials/OriginTrialContext.h"
 #include "core/workers/InProcessWorkerBase.h"
 #include "core/workers/InProcessWorkerObjectProxy.h"
 #include "core/workers/WorkerClients.h"
@@ skipping 98 matching lines @@
 
   if (GetWorkerThread()) {
     // A message event is an activity and may initiate another activity.
     worker_global_scope_has_pending_activity_ = true;
     ++unconfirmed_message_count_;
     std::unique_ptr<WTF::CrossThreadClosure> task = CrossThreadBind(
         &InProcessWorkerObjectProxy::ProcessMessageFromWorkerObject,
         CrossThreadUnretained(&WorkerObjectProxy()), std::move(message),
         WTF::Passed(std::move(channels)),
         CrossThreadUnretained(GetWorkerThread()));
-    GetWorkerThread()->PostTask(BLINK_FROM_HERE, std::move(task));
+    TaskRunnerHelper::Get(TaskType::kPostedMessage, GetWorkerThread())
+        ->PostTask(BLINK_FROM_HERE, std::move(task));
   } else {
     queued_early_tasks_.push_back(
         QueuedTask{std::move(message), std::move(channels)});
   }
 }
 
 void InProcessWorkerMessagingProxy::DispatchErrorEvent(
     const String& error_message,
     std::unique_ptr<SourceLocation> location,
     int exception_id) {
@@ skipping 28 matching lines @@
 
   DCHECK_EQ(0u, unconfirmed_message_count_);
   unconfirmed_message_count_ = queued_early_tasks_.size();
   for (auto& queued_task : queued_early_tasks_) {
     std::unique_ptr<WTF::CrossThreadClosure> task = CrossThreadBind(
         &InProcessWorkerObjectProxy::ProcessMessageFromWorkerObject,
         CrossThreadUnretained(&WorkerObjectProxy()),
         queued_task.message.Release(),
         WTF::Passed(std::move(queued_task.channels)),
         CrossThreadUnretained(GetWorkerThread()));
-    GetWorkerThread()->PostTask(BLINK_FROM_HERE, std::move(task));
+    TaskRunnerHelper::Get(TaskType::kPostedMessage, GetWorkerThread())
+        ->PostTask(BLINK_FROM_HERE, std::move(task));
   }
   queued_early_tasks_.Clear();
 }
 
 void InProcessWorkerMessagingProxy::ParentObjectDestroyed() {
   DCHECK(IsParentContextThread());
 
   // parentObjectDestroyed() is called in InProcessWorkerBase's destructor.
   // Thus it should be guaranteed that a weak pointer m_workerObject has been
   // cleared before this method gets called.
@@ skipping 23 matching lines @@
 }
 
 bool InProcessWorkerMessagingProxy::HasPendingActivity() const {
   DCHECK(IsParentContextThread());
   if (AskedToTerminate())
     return false;
   return worker_global_scope_has_pending_activity_;
 }
 
 }  // namespace blink