anonymous — Mon, 15 Aug 2016 15:23:45 GMT

minor compilation issue in the test program. here is updated version:

#include <string>
#include <deque>
#include <cstdio>
#include <boost/lockfree/queue.hpp>
#include <cassert>
#include <iostream>
struct SemTask
{
 int x;
};
boost::lockfree::queue<SemTask * > queue(1);
void* runner(void* arg)
{
    std::cout << '.' << std::endl;
    while (true)
    {
      SemTask * task = new SemTask();
      assert(queue.push(task));
      assert(queue.pop(task));
      delete task;
    }
    return NULL;
}
int main(int argc, char** argv)
{
  assert(queue.is_lock_free());
  #define NUM_THRD 2
  pthread_t inc_x_thread[NUM_THRD];
  for (int i = 0; i < NUM_THRD; ++i) {
    if(pthread_create(&inc_x_thread[i], NULL, runner, NULL)) {
      fprintf(stderr, "Error creating thread\n");
      return -1;
    }
  }
  for (int i = 0; i < NUM_THRD; ++i) {
    if(pthread_join(inc_x_thread[i], NULL)) {
      fprintf(stderr, "Error joining thread\n");
      return -1;
    }
  }
  return 0;
}

Boost C++ Libraries: Ticket #12394: boost::lockfree::queue with gcc-4.6 + optimization