Function runParallel

valdi/test/utils/valdi_test_utils.cpp:308–340

}

void runParallel(size_t threadsCount, int64_t durationSeconds, DispatchFunction run) {
    if (threadsCount > 1) {
        std::vector<Ref<Thread>> threads;
        std::atomic_bool cont = true;

        for (size_t i = 0; i < 8; i++) {
            auto thread = Thread::create(STRING_LITERAL("Worker Thread"), ThreadQoSClassMax, [&]() {
                while (cont) {
                    run();
                }
            });

            SC_ASSERT(thread);

            threads.emplace_back(thread.value());
        }

        std::this_thread::sleep_for(std::chrono::seconds(durationSeconds));

        cont = false;

        for (const auto& thread : threads) {
            thread->join();
        }
    } else {
        snap::utils::time::StopWatch sw;
        sw.start();

        while (sw.elapsedSeconds() < durationSeconds) {
            run();
        }
    }
}

bool runTypeScriptTests(std::string_view modulePath,
                        Valdi::IJavaScriptBridge* jsBridge,