Worker: Introduce per-global-scope task scheduler

third_party/WebKit/Source/modules/time_zone_monitor/TimeZoneMonitorClient.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 "modules/time_zone_monitor/TimeZoneMonitorClient.h"
 
 #include "bindings/core/v8/V8Binding.h"
 #include "bindings/core/v8/V8PerIsolateData.h"
 #include "core/dom/ExecutionContext.h"
+#include "core/dom/TaskRunnerHelper.h"
 #include "core/workers/WorkerBackingThread.h"
 #include "core/workers/WorkerOrWorkletGlobalScope.h"
 #include "core/workers/WorkerThread.h"
 #include "platform/CrossThreadFunctional.h"
 #include "public/platform/Platform.h"
 #include "services/device/public/interfaces/constants.mojom-blink.h"
 #include "services/service_manager/public/cpp/connector.h"
 #include "third_party/icu/source/i18n/unicode/timezone.h"
 #include "v8/include/v8.h"
 
@@ skipping 43 matching lines @@
   NotifyTimezoneChangeToV8(V8PerIsolateData::MainThreadIsolate());
 
   HashSet<WorkerThread*>& threads = WorkerThread::WorkerThreads();
   HashSet<WorkerBackingThread*> posted;
   for (WorkerThread* thread : threads) {
     // Ensure every WorkerBackingThread(holding one platform thread) only get
     // the task posted once, because one WorkerBackingThread could be shared
     // among multiple WorkerThreads.
     if (posted.Contains(&thread->GetWorkerBackingThread()))
       continue;
-    thread->PostTask(BLINK_FROM_HERE,
-                     CrossThreadBind(&NotifyTimezoneChangeOnWorkerThread,
-                                     WTF::CrossThreadUnretained(thread)));
+    TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)

[haraken, 2017/04/13 07:03:36]

Why kUnthrottled?

[nhiroki, 2017/04/13 08:23:50]

Hm... this should be kUnspecedTimer. Replaced.

+        ->PostTask(BLINK_FROM_HERE,
+                   CrossThreadBind(&NotifyTimezoneChangeOnWorkerThread,
+                                   WTF::CrossThreadUnretained(thread)));
     posted.insert(&thread->GetWorkerBackingThread());
   }
 }
 
 }  // namespace blink