src/threadsafety.h

#ifndef express_thread_safety_h
#define express_thread_safety_h

#include <boost/thread.hpp>
#include <queue>

class Fragment;

class ThreadSafeFragQueue {
  std::queue<Fragment*> _queue;
  size_t _max_size;
  boost::mutex _mut;
  boost::condition_variable _cond;

 public:
  ThreadSafeFragQueue(size_t max_size);
  Fragment* pop(bool block=true);
  void push(Fragment* frag);
  bool is_empty(bool block=false);
};

struct ParseThreadSafety {
  ThreadSafeFragQueue proc_in;
  ThreadSafeFragQueue proc_on;
  ThreadSafeFragQueue proc_out;
  ParseThreadSafety(size_t q_size)
      : proc_in(q_size), proc_on(q_size), proc_out(q_size) {
  }
};

#endif