#include "spscq.hpp"
#include <thread>

int main() {
    // Create a queue with capacity for 1024 elements
    spscq<int> queue(1024);
    
    // Producer thread
    std::thread producer(
        [&queue] () {
            for (int i = 0; i < 100; ++i) 
            {
                while (!queue.try_push(i));
            }
        }
    );
    
    // Consumer thread
    std::thread consumer(
        [&queue] () {
            int value;
            for (int i = 0; i < 100; ++i) 
            {
                while (!queue.try_pop(value));
            }
        }
    );
    
    producer.join();
    consumer.join();
}