Function demonstrateSpinLock

examples/threading_patterns.cpp:62–105

}

void demonstrateSpinLock()
{
    std::cout << "\n=== SpinLock Demo ===\n";

    choc::threading::SpinLock spinLock;
    std::atomic<int> sharedCounter{0};
    std::vector<std::thread> threads;
    constexpr int numThreads = 4;
    constexpr int incrementsPerThread = 1000;

    auto workerFunction = [&](int threadId)
    {
        for (int i = 0; i < incrementsPerThread; ++i)
        {
            // Critical section protected by spin lock
            {
                std::scoped_lock lock (spinLock);
                int current = sharedCounter.load();
                // Simulate some work
                std::this_thread::sleep_for (std::chrono::microseconds (1));
                sharedCounter.store (current + 1);
            }
        }

        std::cout << "Thread " << threadId << " completed\n";
    };

    auto startTime = std::chrono::steady_clock::now();

    // Start worker threads
    for (int i = 0; i < numThreads; ++i)
        threads.emplace_back (workerFunction, i);

    // Wait for all threads to complete
    for (auto& t : threads)
        t.join();

    auto endTime = std::chrono::steady_clock::now();
    auto duration = std::chrono::duration_cast<std::chrono::milliseconds>(endTime - startTime);

    std::cout << "SpinLock test completed in " << duration.count() << "ms\n";
    std::cout << "Expected: " << (numThreads * incrementsPerThread) << ", Actual: " << sharedCounter.load() << "\n";
    std::cout << "Result: " << (sharedCounter.load() == numThreads * incrementsPerThread ? "PASS" : "FAIL") << "\n";
}

void demonstrateThreadSafeFunctor()
{