| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2008 Apple Inc. All Rights Reserved. | 2 * Copyright (C) 2008 Apple Inc. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
| 5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
| 6 * are met: | 6 * are met: |
| 7 * 1. Redistributions of source code must retain the above copyright | 7 * 1. Redistributions of source code must retain the above copyright |
| 8 * notice, this list of conditions and the following disclaimer. | 8 * notice, this list of conditions and the following disclaimer. |
| 9 * 2. Redistributions in binary form must reproduce the above copyright | 9 * 2. Redistributions in binary form must reproduce the above copyright |
| 10 * notice, this list of conditions and the following disclaimer in the | 10 * notice, this list of conditions and the following disclaimer in the |
| (...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 99 NotTerminated, | 99 NotTerminated, |
| 100 GracefullyTerminated, | 100 GracefullyTerminated, |
| 101 SyncForciblyTerminated, | 101 SyncForciblyTerminated, |
| 102 AsyncForciblyTerminated, | 102 AsyncForciblyTerminated, |
| 103 LastEnum, | 103 LastEnum, |
| 104 }; | 104 }; |
| 105 | 105 |
| 106 virtual ~WorkerThread(); | 106 virtual ~WorkerThread(); |
| 107 | 107 |
| 108 // Called on the main thread. | 108 // Called on the main thread. |
| 109 void start(std::unique_ptr<WorkerThreadStartupData>); | 109 void start(std::unique_ptr<WorkerThreadStartupData>, ParentFrameTaskRunners*); |
| 110 void terminate(); | 110 void terminate(); |
| 111 | 111 |
| 112 // Called on the main thread. Internally calls terminateInternal() and wait | 112 // Called on the main thread. Internally calls terminateInternal() and wait |
| 113 // (by *blocking* the calling thread) until the worker(s) is/are shut down. | 113 // (by *blocking* the calling thread) until the worker(s) is/are shut down. |
| 114 void terminateAndWait(); | 114 void terminateAndWait(); |
| 115 static void terminateAndWaitForAllWorkers(); | 115 static void terminateAndWaitForAllWorkers(); |
| 116 | 116 |
| 117 // WebThread::TaskObserver. | 117 // WebThread::TaskObserver. |
| 118 void willProcessTask() override; | 118 void willProcessTask() override; |
| 119 void didProcessTask() override; | 119 void didProcessTask() override; |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 168 | 168 |
| 169 bool isForciblyTerminated(); | 169 bool isForciblyTerminated(); |
| 170 | 170 |
| 171 void waitForShutdownForTesting() { m_shutdownEvent->wait(); } | 171 void waitForShutdownForTesting() { m_shutdownEvent->wait(); } |
| 172 | 172 |
| 173 ParentFrameTaskRunners* getParentFrameTaskRunners() const { | 173 ParentFrameTaskRunners* getParentFrameTaskRunners() const { |
| 174 return m_parentFrameTaskRunners.get(); | 174 return m_parentFrameTaskRunners.get(); |
| 175 } | 175 } |
| 176 | 176 |
| 177 protected: | 177 protected: |
| 178 WorkerThread(PassRefPtr<WorkerLoaderProxy>, | 178 WorkerThread(PassRefPtr<WorkerLoaderProxy>, WorkerReportingProxy&); |
| 179 WorkerReportingProxy&, | |
| 180 ParentFrameTaskRunners*); | |
| 181 | 179 |
| 182 // Factory method for creating a new worker context for the thread. | 180 // Factory method for creating a new worker context for the thread. |
| 183 // Called on the worker thread. | 181 // Called on the worker thread. |
| 184 virtual WorkerOrWorkletGlobalScope* createWorkerGlobalScope( | 182 virtual WorkerOrWorkletGlobalScope* createWorkerGlobalScope( |
| 185 std::unique_ptr<WorkerThreadStartupData>) = 0; | 183 std::unique_ptr<WorkerThreadStartupData>) = 0; |
| 186 | 184 |
| 187 // Returns true when this WorkerThread owns the associated | 185 // Returns true when this WorkerThread owns the associated |
| 188 // WorkerBackingThread exclusively. If this function returns true, the | 186 // WorkerBackingThread exclusively. If this function returns true, the |
| 189 // WorkerThread initializes / shutdowns the backing thread. Otherwise | 187 // WorkerThread initializes / shutdowns the backing thread. Otherwise |
| 190 // workerBackingThread() should be initialized / shutdown properly | 188 // workerBackingThread() should be initialized / shutdown properly |
| (...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 311 | 309 |
| 312 // Created on the main thread heap, but will be accessed cross-thread | 310 // Created on the main thread heap, but will be accessed cross-thread |
| 313 // when worker thread posts tasks. | 311 // when worker thread posts tasks. |
| 314 CrossThreadPersistent<WorkerThreadLifecycleContext> | 312 CrossThreadPersistent<WorkerThreadLifecycleContext> |
| 315 m_workerThreadLifecycleContext; | 313 m_workerThreadLifecycleContext; |
| 316 }; | 314 }; |
| 317 | 315 |
| 318 } // namespace blink | 316 } // namespace blink |
| 319 | 317 |
| 320 #endif // WorkerThread_h | 318 #endif // WorkerThread_h |
| OLD | NEW |