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 21 matching lines...) Expand all Loading... |
32 #include "core/workers/WorkerGlobalScope.h" | 32 #include "core/workers/WorkerGlobalScope.h" |
33 #include "platform/SharedTimer.h" | 33 #include "platform/SharedTimer.h" |
34 #include "platform/WebThreadSupportingGC.h" | 34 #include "platform/WebThreadSupportingGC.h" |
35 #include "platform/weborigin/SecurityOrigin.h" | 35 #include "platform/weborigin/SecurityOrigin.h" |
36 #include "wtf/Forward.h" | 36 #include "wtf/Forward.h" |
37 #include "wtf/MessageQueue.h" | 37 #include "wtf/MessageQueue.h" |
38 #include "wtf/OwnPtr.h" | 38 #include "wtf/OwnPtr.h" |
39 #include "wtf/PassRefPtr.h" | 39 #include "wtf/PassRefPtr.h" |
40 #include "wtf/RefCounted.h" | 40 #include "wtf/RefCounted.h" |
41 | 41 |
| 42 namespace v8 { |
| 43 class Isolate; |
| 44 } |
| 45 |
42 namespace blink { | 46 namespace blink { |
43 | 47 |
44 class WebWaitableEvent; | 48 class WebWaitableEvent; |
45 class WorkerGlobalScope; | 49 class WorkerGlobalScope; |
46 class WorkerInspectorController; | 50 class WorkerInspectorController; |
47 class WorkerLoaderProxy; | 51 class WorkerLoaderProxy; |
48 class WorkerReportingProxy; | 52 class WorkerReportingProxy; |
49 class WorkerSharedTimer; | 53 class WorkerSharedTimer; |
50 class WorkerThreadShutdownFinishTask; | 54 class WorkerThreadShutdownFinishTask; |
51 class WorkerThreadStartupData; | 55 class WorkerThreadStartupData; |
52 class WorkerThreadTask; | 56 class WorkerThreadTask; |
53 | 57 |
54 enum WorkerThreadStartMode { | 58 enum WorkerThreadStartMode { |
55 DontPauseWorkerGlobalScopeOnStart, | 59 DontPauseWorkerGlobalScopeOnStart, |
56 PauseWorkerGlobalScopeOnStart | 60 PauseWorkerGlobalScopeOnStart |
57 }; | 61 }; |
58 | 62 |
59 class WorkerThread : public RefCounted<WorkerThread> { | 63 class WorkerThread : public RefCounted<WorkerThread> { |
60 public: | 64 public: |
61 virtual ~WorkerThread(); | 65 virtual ~WorkerThread(); |
62 | 66 |
63 virtual void start(); | 67 virtual void start(); |
64 virtual void stop(); | 68 virtual void stop(); |
65 | 69 |
| 70 virtual v8::Isolate* initializeIsolate(); |
| 71 virtual PassOwnPtr<WebThreadSupportingGC> createWebThreadSupportingGC(); |
| 72 |
66 // Can be used to wait for this worker thread to shut down. | 73 // Can be used to wait for this worker thread to shut down. |
67 // (This is signalled on the main thread, so it's assumed to be waited on th
e worker context thread) | 74 // (This is signalled on the main thread, so it's assumed to be waited on th
e worker context thread) |
68 WebWaitableEvent* shutdownEvent() { return m_shutdownEvent.get(); } | 75 WebWaitableEvent* shutdownEvent() { return m_shutdownEvent.get(); } |
69 | 76 |
70 WebWaitableEvent* terminationEvent() { return m_terminationEvent.get(); } | 77 WebWaitableEvent* terminationEvent() { return m_terminationEvent.get(); } |
71 void terminateAndWait(); | 78 void terminateAndWait(); |
72 static void terminateAndWaitForAllWorkers(); | 79 static void terminateAndWaitForAllWorkers(); |
73 | 80 |
74 bool isCurrentThread() const; | 81 bool isCurrentThread() const; |
75 WorkerLoaderProxy& workerLoaderProxy() const { return m_workerLoaderProxy; } | 82 WorkerLoaderProxy& workerLoaderProxy() const { return m_workerLoaderProxy; } |
(...skipping 10 matching lines...) Expand all Loading... |
86 void willEnterNestedLoop(); | 93 void willEnterNestedLoop(); |
87 void didLeaveNestedLoop(); | 94 void didLeaveNestedLoop(); |
88 | 95 |
89 WorkerGlobalScope* workerGlobalScope() const { return m_workerGlobalScope.ge
t(); } | 96 WorkerGlobalScope* workerGlobalScope() const { return m_workerGlobalScope.ge
t(); } |
90 bool terminated(); | 97 bool terminated(); |
91 | 98 |
92 // Number of active worker threads. | 99 // Number of active worker threads. |
93 static unsigned workerThreadCount(); | 100 static unsigned workerThreadCount(); |
94 | 101 |
95 PlatformThreadId platformThreadId() const; | 102 PlatformThreadId platformThreadId() const; |
| 103 v8::Isolate* isolate() const; |
96 | 104 |
97 void interruptAndDispatchInspectorCommands(); | 105 void interruptAndDispatchInspectorCommands(); |
98 void setWorkerInspectorController(WorkerInspectorController*); | 106 void setWorkerInspectorController(WorkerInspectorController*); |
99 | 107 |
100 protected: | 108 protected: |
101 WorkerThread(WorkerLoaderProxy&, WorkerReportingProxy&, PassOwnPtrWillBeRawP
tr<WorkerThreadStartupData>); | 109 WorkerThread(WorkerLoaderProxy&, WorkerReportingProxy&, PassOwnPtrWillBeRawP
tr<WorkerThreadStartupData>); |
102 | 110 |
103 // Factory method for creating a new worker context for the thread. | 111 // Factory method for creating a new worker context for the thread. |
104 virtual PassRefPtrWillBeRawPtr<WorkerGlobalScope> createWorkerGlobalScope(Pa
ssOwnPtrWillBeRawPtr<WorkerThreadStartupData>) = 0; | 112 virtual PassRefPtrWillBeRawPtr<WorkerGlobalScope> createWorkerGlobalScope(Pa
ssOwnPtrWillBeRawPtr<WorkerThreadStartupData>) = 0; |
105 | 113 |
(...skipping 25 matching lines...) Expand all Loading... |
131 Mutex m_threadCreationMutex; | 139 Mutex m_threadCreationMutex; |
132 RefPtrWillBePersistent<WorkerGlobalScope> m_workerGlobalScope; | 140 RefPtrWillBePersistent<WorkerGlobalScope> m_workerGlobalScope; |
133 OwnPtrWillBePersistent<WorkerThreadStartupData> m_startupData; | 141 OwnPtrWillBePersistent<WorkerThreadStartupData> m_startupData; |
134 | 142 |
135 // Used to signal thread shutdown. | 143 // Used to signal thread shutdown. |
136 OwnPtr<WebWaitableEvent> m_shutdownEvent; | 144 OwnPtr<WebWaitableEvent> m_shutdownEvent; |
137 | 145 |
138 // Used to signal thread termination. | 146 // Used to signal thread termination. |
139 OwnPtr<WebWaitableEvent> m_terminationEvent; | 147 OwnPtr<WebWaitableEvent> m_terminationEvent; |
140 | 148 |
| 149 v8::Isolate* m_isolate; |
| 150 |
141 // FIXME: This has to be last because of crbug.com/401397 - the | 151 // FIXME: This has to be last because of crbug.com/401397 - the |
142 // WorkerThread might get deleted before it had a chance to properly | 152 // WorkerThread might get deleted before it had a chance to properly |
143 // shut down. By deleting the WebThread first, we can guarantee that | 153 // shut down. By deleting the WebThread first, we can guarantee that |
144 // no pending tasks on the thread might want to access any of the other | 154 // no pending tasks on the thread might want to access any of the other |
145 // members during the WorkerThread's destruction. | 155 // members during the WorkerThread's destruction. |
146 OwnPtr<WebThreadSupportingGC> m_thread; | 156 OwnPtr<WebThreadSupportingGC> m_thread; |
147 }; | 157 }; |
148 | 158 |
149 } // namespace blink | 159 } // namespace blink |
150 | 160 |
151 #endif // WorkerThread_h | 161 #endif // WorkerThread_h |
OLD | NEW |