Function demonstrateRealTimeAudioPattern

examples/threading_patterns.cpp:382–469

}

void demonstrateRealTimeAudioPattern()
{
    std::cout << "\n=== Real-Time Audio Pattern Demo ===\n";

    // Simulate a real-time audio callback pattern
    constexpr int sampleRate = 44100;
    constexpr int bufferSize = 512;
    constexpr int numChannels = 2;

    choc::fifo::SingleReaderSingleWriterFIFO<std::vector<float>> audioFIFO;
    audioFIFO.reset (8); // 8 buffer capacity

    std::atomic<bool> isRunning{true};
    std::atomic<int> buffersProcessed{0};
    std::atomic<int> underruns{0};

    // Audio generator thread (simulates audio callback)
    std::thread audioThread ([&]()
    {
        std::random_device rd;
        std::mt19937 gen (rd());
        std::uniform_real_distribution<float> dist (-0.1f, 0.1f);

        while (isRunning.load())
        {
            std::vector<float> audioBuffer (bufferSize * numChannels);

            // Generate some audio data (white noise)
            for (auto& sample : audioBuffer)
                sample = dist (gen);

            if (audioFIFO.push (std::move (audioBuffer)))
            {
                buffersProcessed.fetch_add (1);
            }
            else
            {
                underruns.fetch_add (1);
                std::cout << "Audio buffer underrun!\n";
            }

            // Simulate audio callback timing
            std::this_thread::sleep_for (std::chrono::microseconds ((bufferSize * 1000000) / sampleRate));
        }
    });

    // Audio processing thread
    std::thread processingThread ([&]()
    {
        std::vector<float> buffer;

        while (isRunning.load() || audioFIFO.getUsedSlots() > 0)
        {
            if (audioFIFO.pop (buffer))
            {
                // Simulate audio processing (calculate RMS)
                float rms = 0.0f;