/home/mhx/git/github/libmoost/include/moost/thread/simple_job_scheduler.hpp

Go to the documentation of this file.

/* vim:set ts=3 sw=3 sts=3 et: */
#ifndef MOOST_THREAD_SIMPLE_JOB_SCHEDULER_HPP
#define MOOST_THREAD_SIMPLE_JOB_SCHEDULER_HPP

#include <string>
#include <vector>

#include <boost/shared_ptr.hpp>
#include <boost/noncopyable.hpp>
#include <boost/bind.hpp>

#include "job_batch.hpp"

namespace moost { namespace thread {

class simple_job_batch : public job_batch
                       , public boost::noncopyable
{
public:
   simple_job_batch()
      : m_count(0)
   {
   }

   virtual void add(job_t job)
   {
      try
      {
         job();  // JFDI! :)
      }
      catch (const std::exception& e)
      {
         m_errors.push_back(e.what());
      }
      catch (...)
      {
         m_errors.push_back("unknown exception caught");
      }

      ++m_count;
   }

   void run()
   {
   }

   size_t count() const
   {
      return m_count;
   }

   const std::vector<std::string>& errors() const
   {
      return m_errors;
   }

private:
   size_t m_count;
   std::vector<std::string> m_errors;
};

class simple_job_scheduler : public boost::noncopyable
{
public:
   typedef simple_job_batch job_batch_type;

   void dispatch(boost::shared_ptr<job_batch_type>)
   {
   }
};

}}

#endif