Function queueTask

src/runtime.cpp:70–100

}

void* queueTask(const std::function<void*(void*)>& func, void* arg, bool async) {
    if (std::this_thread::get_id() == mainThreadID && (!async || taskQueue.locked())) return func(arg);
    TaskQueueItem * task = new TaskQueueItem;
    task->func = func;
    task->data = arg;
    task->async = async;
    {
        std::unique_lock<std::mutex> lock(taskQueue.getMutex());
        taskQueue->push(task);
        if (selectedRenderer == 0 || selectedRenderer == 5) {
            SDL_Event e;
            e.type = task_event_type;
            SDL_PushEvent(&e);
        }
        taskQueueReady = true;
        taskQueueNotify.notify_all();
    }
    if (async) return NULL;
    {
        std::unique_lock<std::mutex> lock(task->lock);
        while (!task->ready) task->notify.wait(lock);
        if (task->exception != nullptr) {
            std::exception_ptr e = task->exception;
            delete task;
            std::rethrow_exception(e);
        }
        arg = task->data;
    }
    delete task;
    return arg;
}

void awaitTasks(const std::function<bool()>& predicate = []()->bool{return true;}) {
    while (predicate()) {