shutdown_policies.hpp

Go to the documentation of this file.

#ifndef THREADPOOL_SHUTDOWN_POLICIES_HPP_INCLUDED
#define THREADPOOL_SHUTDOWN_POLICIES_HPP_INCLUDED



namespace boost { namespace threadpool
{


  template<typename Pool>
  class wait_for_all_tasks
  {
  public:
    static void shutdown(Pool& pool)
    {
      pool.wait();
      pool.terminate_all_workers(true);
    }
  };


  template<typename Pool>
  class wait_for_active_tasks
  {
  public:
    static void shutdown(Pool& pool)
    {
      pool.clear();
      pool.wait();
      pool.terminate_all_workers(true);
    }
  };


  template<typename Pool>
  class immediately
  {
  public:
    static void shutdown(Pool& pool)
    {
      pool.clear();
      pool.terminate_all_workers(false);
    }
  };

} } // namespace boost::threadpool

#endif // THREADPOOL_SHUTDOWN_POLICIES_HPP_INCLUDED