Function TEST

valdi/test/runtime/Threading_tests.cpp:19–34

#include <thread>

using namespace Valdi;

namespace ValdiTest {

TEST(ThreadedDispatchQueue, startsThreadOnFirstTaskEnqueued) {
    auto dispatchQueue = makeShared<ThreadedDispatchQueue>(STRING_LITERAL("Test Queue"), ThreadQoSClassNormal);

    ASSERT_FALSE(dispatchQueue->hasThreadRunning());

    bool didRun = false;
    dispatchQueue->sync([&]() { didRun = true; });

    ASSERT_TRUE(didRun);
    // Sync calls should not trigger the thread creation
    ASSERT_FALSE(dispatchQueue->hasThreadRunning());

    dispatchQueue->async([]() {});

    ASSERT_TRUE(dispatchQueue->hasThreadRunning());