Method testBarrier

Tests/Libraries/Threading/ThreadingTest.cpp:198–239

}

void SC::ThreadingTest::testBarrier()
{
    //! [barrierSnippet]
    constexpr uint32_t numThreads          = 8;
    constexpr int      incrementsPerThread = 1000;

    Thread threads[numThreads];

    Barrier barrier(numThreads);
    struct Context
    {
        Barrier&        barrier;
        Atomic<int32_t> sharedCounter;
    } ctx = {barrier, 0};

    for (uint32_t i = 0; i < numThreads; i++)
    {
        auto threadFunc = [this, &ctx](Thread& thread)
        {
            thread.setThreadName(SC_NATIVE_STR("Barrier"));

            // Phase 1: Each thread increments the counter
            for (int j = 0; j < incrementsPerThread; ++j)
            {
                ctx.sharedCounter++;
            }
            ctx.barrier.wait();

            // Phase 2: All threads should see the final value
            SC_TEST_EXPECT(ctx.sharedCounter == numThreads * incrementsPerThread);
            ctx.barrier.wait();
        };
        SC_TEST_EXPECT(threads[i].start(threadFunc));
    }

    // Wait for all threads to finish
    for (uint32_t i = 0; i < numThreads; i++)
    {
        SC_TEST_EXPECT(threads[i].join());
    }
    //! [barrierSnippet]
}

void SC::ThreadingTest::testSemaphore()
{