blob: f80db160f08a47d5af0a864968a8282cd5a117db (
plain)
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 | // 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#include"qwasmglobal_p.h"namespace qwasmglobal {Q_GLOBAL_STATIC(emscripten::ProxyingQueue, proxyingQueue);namespace{voidtrampoline(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);}}voidrunOnMainThread(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.voidrunAsync(std::function<void(void)> fn){Q_ASSERT(emscripten_is_main_runtime_thread());trampoline(newstd::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.voidrunOnMainThreadAsync(std::function<void(void)> fn){void*context =newstd::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;}#endiftrampoline(context);}}
|
