Ticket #11490: spsc_queue_interprocess_test.cpp

#include <cstdlib> //std::system
#include <sstream>

#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/lockfree/spsc_queue.hpp>

using namespace boost::interprocess;
typedef allocator<int, managed_shared_memory::segment_manager> ShmemAllocator;
typedef boost::lockfree::spsc_queue<int, boost::lockfree::allocator<ShmemAllocator> > queue;

int main (int argc, char *argv[])
{
    struct shm_remove
    {
        shm_remove() {  shared_memory_object::remove("spsc_queue_interprocess_shm"); }
        ~shm_remove(){  shared_memory_object::remove("spsc_queue_interprocess_shm"); }
    } remover;

    managed_shared_memory segment(create_only, "spsc_queue_interprocess_shm", 10000);
    ShmemAllocator alloc_inst(segment.get_segment_manager());

    queue* q = segment.construct<queue>("queue")(1000, alloc_inst);

    int i = 2;
    q->push(i);
    q->pop(i);

    fprintf(stdout, "i: %d\n", i);

    segment.destroy<queue>("queue");

    return 0;
}