#include <boost/thread/thread.hpp>

#include <boost/lockfree/spsc_queue.hpp>

#include <iostream>

#include <boost/atomic.hpp>

int producer_count = ;

boost::atomic_int consumer_count ();

boost::lockfree::spsc_queue<int, boost::lockfree::capacity<> > spsc_queue;//但生产者但消费者队列，后面是指定其容量大小

const int iterations = ;

void producer(void)

{

    for (int i = ; i != iterations; ++i) {

        int value = ++producer_count;

        while (!spsc_queue.push(value))

            ;

    }

}

boost::atomic<bool> done (false);

void consumer(void)

{

    int value;

    while (!done) {

        while (spsc_queue.pop(value))

            ++consumer_count;

    }

    while (spsc_queue.pop(value))

        ++consumer_count;

}

int main(int argc, char* argv[])

{

    using namespace std;

    cout << "boost::lockfree::queue is ";

    if (!spsc_queue.is_lock_free())

        cout << "not ";

    cout << "lockfree" << endl;

    boost::thread producer_thread(producer);//单生产者

    boost::thread consumer_thread(consumer);//单消费者

    producer_thread.join();

    done = true;

    consumer_thread.join();

    cout << "produced " << producer_count << " objects." << endl;

    cout << "consumed " << consumer_count << " objects." << endl;

    getchar();

}