Introduce WebTaskRunner Patch 3/5

Source/core/workers/WorkerThread.cpp

 /*
  * Copyright (C) 2008 Apple 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
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 92 matching lines @@
     DEFINE_STATIC_LOCAL(HashSet<WorkerThread*>, threads, ());
     return threads;
 }
 
 unsigned WorkerThread::workerThreadCount()
 {
     MutexLocker lock(threadSetMutex());
     return workerThreads().size();
 }
 
-class WorkerThreadTask : public WebThread::Task {
+class WorkerThreadTask : public WebTaskRunner::Task {
     WTF_MAKE_NONCOPYABLE(WorkerThreadTask); WTF_MAKE_FAST_ALLOCATED(WorkerThreadTask);
 public:
     static PassOwnPtr<WorkerThreadTask> create(WorkerThread& workerThread, PassOwnPtr<ExecutionContextTask> task, bool isInstrumented)
     {
         return adoptPtr(new WorkerThreadTask(workerThread, task, isInstrumented));
     }
 
     ~WorkerThreadTask() override { }
 
     void run() override
@@ skipping 344 matching lines @@
     ASSERT(isCurrentThread());
     V8PerIsolateData::destroy(m_isolate);
 }
 
 void WorkerThread::terminateV8Execution()
 {
     ASSERT(isMainThread());
     v8::V8::TerminateExecution(m_isolate);
 }
 
-void WorkerThread::appendDebuggerTask(PassOwnPtr<WebThread::Task> task)
+void WorkerThread::appendDebuggerTask(PassOwnPtr<WebTaskRunner::Task> task)
 {
     {
         MutexLocker lock(m_threadStateMutex);
         if (m_shutdown)
             return;
     }
     m_debuggerMessageQueue.append(task);
 }
 
 MessageQueueWaitResult WorkerThread::runDebuggerTask(WaitMode waitMode)
 {
     ASSERT(isCurrentThread());
     MessageQueueWaitResult result;
-    double absoluteTime = MessageQueue<WebThread::Task>::infiniteTime();
-    OwnPtr<WebThread::Task> task;
+    double absoluteTime = MessageQueue<WebTaskRunner::Task>::infiniteTime();
+    OwnPtr<WebTaskRunner::Task> task;
     {
         if (waitMode == DontWaitForMessage)
             absoluteTime = 0.0;
         SafePointScope safePointScope(ThreadState::NoHeapPointersOnStack);
         task = m_debuggerMessageQueue.waitForMessageWithTimeout(result, absoluteTime);
     }
 
     if (result == MessageQueueMessageReceived) {
         InspectorInstrumentation::willProcessTask(workerGlobalScope());
         task->run();
@@ skipping 13 matching lines @@
     InspectorInstrumentation::didLeaveNestedRunLoop(m_workerGlobalScope.get());
 }
 
 void WorkerThread::setWorkerInspectorController(WorkerInspectorController* workerInspectorController)
 {
     MutexLocker locker(m_workerInspectorControllerMutex);
     m_workerInspectorController = workerInspectorController;
 }
 
 } // namespace blink