scheduling_policies.hpp

Go to the documentation of this file.

#ifndef THREADPOOL_SCHEDULING_POLICIES_HPP_INCLUDED
#define THREADPOOL_SCHEDULING_POLICIES_HPP_INCLUDED


#include <queue>
#include <deque>

#include "task_adaptors.hpp"

namespace boost { namespace threadpool
{

  template <typename Task = task_func>  
  class fifo_scheduler
  {
  public:
    typedef Task task_type; 

  protected:
    std::deque<task_type> m_container;  


  public:
    bool push(task_type const & task)
    {
      m_container.push_back(task);
      return true;
    }

    void pop()
    {
      m_container.pop_front();
    }

    task_type const & top() const
    {
      return m_container.front();
    }

    size_t size() const
    {
      return m_container.size();
    }

    bool empty() const
    {
      return m_container.empty();
    }

    void clear()
    {   
      m_container.clear();
    } 
  };



  template <typename Task = task_func>  
  class lifo_scheduler
  {
  public:
    typedef Task task_type;  

  protected:
    std::deque<task_type> m_container;  

  public:
    bool push(task_type const & task)
    {
      m_container.push_front(task);
      return true;
    }

    void pop()
    {
      m_container.pop_front();
    }

    task_type const & top() const
    {
      return m_container.front();
    }

    size_t size() const
    {
      return m_container.size();
    }

    bool empty() const
    {
      return m_container.empty();
    }

    void clear()
    {    
      m_container.clear();
    } 

  };



  template <typename Task = prio_task_func>  
  class prio_scheduler
  {
  public:
    typedef Task task_type; 

  protected:
    std::priority_queue<task_type> m_container;  


  public:
    bool push(task_type const & task)
    {
      m_container.push(task);
      return true;
    }

    void pop()
    {
      m_container.pop();
    }

    task_type const & top() const
    {
      return m_container.top();
    }

    size_t size() const
    {
      return m_container.size();
    }

    bool empty() const
    {
      return m_container.empty();
    }

    void clear()
    {    
      while(!m_container.empty())
      {
        m_container.pop();
      }
    } 
  };


} } // namespace boost::threadpool


#endif // THREADPOOL_SCHEDULING_POLICIES_HPP_INCLUDED