toast/async/locking_queue.hpp

#ifndef toast_async_locking_queue_hpp_INCLUDED
#define toast_async_locking_queue_hpp_INCLUDED

#include <list>
#include <boost/thread/mutex.hpp>

namespace toast {
namespace async {

template <typename T>
class locking_queue
{
  std::list<T> list_;
  boost::mutex mutex_;
public:
  void push(std::list<T> &l)
  {
    boost::mutex::scoped_lock lock(mutex_);
    list_.splice(list_.end(), l);
  }

  void push(T const &t)
  {
    std::list<T> temp(1, t);
    push(temp);
  }

  void pop_one(std::list<T> &l)
  {
    boost::mutex::scoped_lock lock(mutex_);
    if(!list_.empty())
      l.splice(l.end(), list_, list_.begin());
  }
  
  void pop(std::list<T> &l)
  {
    boost::mutex::scoped_lock lock(mutex_);
    l.splice(l.end(), list_);
  }
};

} // namespace async
} // namespace toast

#endif // toast_async_locking_queue_hpp_INCLUDED

---