toast/async/thread_specific_request_queue.hpp

#ifndef toast_async_dispatcher_hpp_INCLUDED
#define toast_async_dispatcher_hpp_INCLUDED

#include <list>
#include <boost/bind.hpp>
#include <toast/async/request.hpp>

namespace toast {
namespace async {

namespace detail {

template <typename T, typename U, typename V>
void request_helper(T const &f,
                                        U const &c,
                                        V const &push)
{
  std::list<request> temp(1, boost::bind(c, f()));
  push(temp);
}


}

class thread_specific_request_queue
{
  thread_specific_request_queue();
public:
  static boost::function<void (std::list<request> &)> get_push();

  static void pop_one(std::list<request> &);

  static void pop(std::list<request> &);

  static  boost::function<void ()> on_push(boost::function<void ()> const &);
};

template <typename T>
request make_request(boost::function<T ()> const &f,
  boost::function<void (T)> const &c)
{
        return boost::bind(&detail::request_helper<
                                           boost::function<T ()>,
                                           boost::function<void (T)>,
                                           boost::function<void (std::list<request> &)> >,
                                           f,
                                           c,
                                           thread_specific_request_queue::get_push());
}

} // namespace async
} // namespace toast

#endif // toast_async_dispatcher_hpp_INCLUDED

---