threaded queue.cpp

#include <iostream>
#include <boost/thread.hpp>
#include <boost/functional.hpp>
#include <boost/lockfree/spsc_queue.hpp>

using namespace std;

void workerFunc(const char* msg, boost::lockfree::spsc_queue<int, boost::lockfree::capacity<1024>> *queue)
{
  for(int i=1; i<=1000; i++){
	queue->push(i);
  }
  cout << "DONE";
}

int main()
{
    std::cout << "main: startup" << std::endl;
	boost::lockfree::spsc_queue<int, boost::lockfree::capacity<1024>> queue;
    const char* name = "Hello world";
    boost::thread workerThread(workerFunc, name, &queue);
	int result = 0;
	bool has;
	while(true){
	  has = queue.pop(&result);
	  if(has){
		cout <<  " RESULT:" << result << " " << has << endl;
	  }else {
		cout << has;
	  }
	}
    // edit: fixed in response to comment
    return 0;
}