Method sync

valdi_core/src/valdi_core/cpp/Threading/ThreadedDispatchQueue.cpp:52–77

}

void ThreadedDispatchQueue::sync(const Valdi::DispatchFunction& function) {
    if (_disableSyncCallsInCallingThread) {
        std::promise<void> promise;
        auto future = promise.get_future();

        async([&function, &promise, this]() {
            _runningSync = true;
            function();

            promise.set_value();
            _runningSync = false;
        });

        future.get();
        return;
    }

    _taskQueue->barrier([&]() {
        auto* previousCurrent = current;
        current = this;
        _runningSync = true;
        function();
        current = previousCurrent;
        _runningSync = false;
    });
}

void ThreadedDispatchQueue::async(Valdi::DispatchFunction function) {
    auto task = _taskQueue->enqueue(std::move(function));