compositor-worker: Share a thread and an isolate for compositor workers.

Source/modules/compositorworker/CompositorWorkerManager.cpp

Index: Source/modules/compositorworker/CompositorWorkerManager.cpp
diff --git a/Source/modules/compositorworker/CompositorWorkerManager.cpp b/Source/modules/compositorworker/CompositorWorkerManager.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..3d3dcf7d8f00fba68e5615aaadf1bb817e7b8dce
--- /dev/null
+++ b/Source/modules/compositorworker/CompositorWorkerManager.cpp
@@ -0,0 +1,158 @@
+// Copyright 2015 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 "config.h"
+#include "modules/compositorworker/CompositorWorkerManager.h"
+
+#include "platform/ThreadSafeFunctional.h"
+#include "platform/WebThreadSupportingGC.h"
+#include "wtf/MainThread.h"
+#include "wtf/ThreadingPrimitives.h"
+
+namespace blink {
+
+namespace {
+
+class SharedV8Isolate final : public WorkerV8Isolate {
+    WTF_MAKE_NONCOPYABLE(SharedV8Isolate);
+public:
+    explicit SharedV8Isolate(v8::Isolate* isolate)
+        : m_isolate(isolate) { }
+    ~SharedV8Isolate() override
+    {
+        CompositorWorkerManager::instance()->destroyIsolate();
+    }
+
+private:
+    // WorkerV8Isolate:
+    v8::Isolate* isolate() const override { return m_isolate; }
+    void willDestroy() override
+    {
+        CompositorWorkerManager::instance()->willDestroyIsolate();
+    }
+
+    void terminateExecution() override
+    {
+        CompositorWorkerManager::instance()->terminateIsolate();
+    }
+
+    v8::Isolate* m_isolate;
+};
+
+static CompositorWorkerManager* s_instance = nullptr;

[kinuko, 2015/05/31 15:18:24]

The same question I asked before... this means that we'll be using the same
isolate and worker thread for multiple ExecutionContext, therefore things that
shouldn't be shared could be leaked to another context?  (Have you asked v8 and
security people about this, if not could we do so now?)

[sadrul, 2015/05/31 16:23:42]

I believe we have discussed this before. We can get some more clarification if
desired.

I am curious to know why you think this may be an issue though. For the main
thread, we use a single isolate too, and each page has their own execution
contexts in the shared isolate. Is this much different from that?

+
+static Mutex& singletonMutex()
+{
+    AtomicallyInitializedStaticReference(Mutex, mutex, new Mutex);
+    return mutex;
+}
+
+static void destroyThread(WebThreadSupportingGC* thread)
+{
+    delete thread;
+}
+
+} // namespace
+
+void CompositorWorkerManager::initialize()
+{
+    MutexLocker lock(singletonMutex());
+    ASSERT(!s_instance);
+    s_instance = new CompositorWorkerManager();
+}
+
+void CompositorWorkerManager::shutdown()
+{
+    MutexLocker lock(singletonMutex());
+    if (s_instance)
+        delete s_instance;
+    s_instance = nullptr;
+}
+
+CompositorWorkerManager* CompositorWorkerManager::instance()
+{
+    MutexLocker lock(singletonMutex());
+    ASSERT(s_instance);
+    return s_instance;
+}
+
+CompositorWorkerManager::CompositorWorkerManager()
+{
+}
+
+CompositorWorkerManager::~CompositorWorkerManager()
+{
+}
+
+WebThreadSupportingGC& CompositorWorkerManager::compositorWorkerThread()
+{
+    MutexLocker lock(m_mutex);
+    if (!m_thread) {
+        ASSERT(isMainThread());
+        ASSERT(!m_workerCount);
+        m_thread = WebThreadSupportingGC::create("CompositorWorker Thread");
+    }
+    return *m_thread.get();
+}
+
+void CompositorWorkerManager::initializeBackingThread()
+{
+    ASSERT(m_thread->isCurrentThread());
+    MutexLocker lock(m_mutex);
+    ++m_workerCount;
+    if (m_workerCount == 1)
+        m_thread->initialize();
+}
+
+void CompositorWorkerManager::shutdownBackingThread()
+{
+    MutexLocker lock(m_mutex);
+    ASSERT(m_thread->isCurrentThread());
+    ASSERT(m_workerCount > 0);
+    --m_workerCount;
+    if (m_workerCount == 0) {
+        m_thread->shutdown();
+        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(destroyThread, AllowCrossThreadAccess(m_thread.leakPtr())));
+    }
+}
+
+PassOwnPtr<WorkerV8Isolate> CompositorWorkerManager::createIsolate()
+{
+    MutexLocker lock(m_mutex);
+    ASSERT(m_thread->isCurrentThread());
+    if (!m_isolate)
+        m_isolate = WorkerV8Isolate::createDefault();
+    else if (m_isolate->isolate()->IsExecutionTerminating())
+        m_isolate->isolate()->CancelTerminateExecution();
+    ++m_isolateCount;
+    return adoptPtr(new SharedV8Isolate(m_isolate->isolate()));
+}
+
+void CompositorWorkerManager::willDestroyIsolate()
+{
+    MutexLocker lock(m_mutex);
+    ASSERT(m_thread->isCurrentThread());
+    --m_isolateCount;
+    if (m_isolateCount == 0)
+        m_isolate->willDestroy();
+}
+
+void CompositorWorkerManager::destroyIsolate()
+{
+    MutexLocker lock(m_mutex);
+    if (m_isolateCount == 0)
+        m_isolate = nullptr;
+}
+
+void CompositorWorkerManager::terminateIsolate()
+{
+    MutexLocker lock(m_mutex);
+    ASSERT(isMainThread());
+    if (m_isolateCount > 1)
+        return;
+
+    m_isolate->terminateExecution();
+}
+
+} // namespace blink