Function demonstrateSingleReaderMultipleWriterFIFO

examples/threading_patterns.cpp:232–303

}

void demonstrateSingleReaderMultipleWriterFIFO()
{
    std::cout << "\n=== SingleReaderMultipleWriterFIFO Demo ===\n";

    choc::fifo::SingleReaderMultipleWriterFIFO<Task> fifo;
    fifo.reset (20); // 20 item capacity

    std::atomic<bool> shouldStop{false};
    std::atomic<int> tasksProduced{0};
    std::atomic<int> tasksConsumed{0};

    // Multiple producer threads
    std::vector<std::thread> producers;

    for (int producerId = 0; producerId < 3; ++producerId)
    {
        producers.emplace_back ([&, producerId]()
        {
            int taskID = 0;

            while (! shouldStop.load())
            {
                ++taskID;

                Task task (producerId * 1000 + taskID,
                           "Producer " + std::to_string (producerId) + " task " + std::to_string (taskID));

                if (fifo.push (task))
                {
                    tasksProduced.fetch_add (1);
                    std::cout << "Producer " << producerId << " produced task " << task.id << "\n";
                }
                else
                {
                    std::cout << "FIFO full, producer " << producerId << " couldn't produce task " << task.id << "\n";
                }

                std::this_thread::sleep_for (std::chrono::milliseconds (200 + producerId * 50));
            }
        });
    }

    // Single consumer thread
    std::thread consumer ([&]()
    {
        Task task;
        while (! shouldStop.load() || fifo.getUsedSlots() > 0)
        {
            if (fifo.pop (task))
            {
                tasksConsumed.fetch_add (1);
                auto now = std::chrono::steady_clock::now();
                auto latency = std::chrono::duration_cast<std::chrono::milliseconds>(now - task.timestamp);
                std::cout << "Consumed task " << task.id << " (" << task.description << ") - latency: " << latency.count() << "ms\n";
            }

            std::this_thread::sleep_for (std::chrono::milliseconds (100));
        }