qwasmglobal.cpp

Go to the documentation of this file.

// Copyright (C) 2024 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
// Qt-Security score:significant reason:default
 
#include <QtCore/qglobalstatic.h>
#include "qwasmglobal_p.h"
 
namespace qwasmglobal {
 
Q_GLOBAL_STATIC(emscripten::ProxyingQueue, proxyingQueue);
 
namespace {
    void trampoline(void *context) {
 
        auto async_fn = [](void *context){
            std::function<void(void)> *fn = reinterpret_cast<std::function<void(void)> *>(context);
            (*fn)();
            delete fn;
        };
 
        emscripten_async_call(async_fn, context, 0);
    }
}
 
void runOnMainThread(std::function<void(void)> fn)
{
#if QT_CONFIG(thread)
    runTaskOnMainThread<void>(fn, proxyingQueue());
#else
    runTaskOnMainThread<void>(fn);
#endif
}
 
// Runs a function asynchronously. Main thread only.
void runAsync(std::function<void(void)> fn)
{
    Q_ASSERT(emscripten_is_main_runtime_thread());
    trampoline(new std::function<void(void)>(fn));
}
 
// Runs a function on the main thread. The function always runs asynchronously,
// also if the calling thread is the main thread.
void runOnMainThreadAsync(std::function<void(void)> fn)
{
    void *context = new std::function<void(void)>(fn);
#if QT_CONFIG(thread)
    if (!emscripten_is_main_runtime_thread()) {
        proxyingQueue()->proxyAsync(emscripten_main_runtime_thread_id(), [context]{
            trampoline(context);
        });
        return;
    }
#endif
    trampoline(context);
}
 
}