executor.hpp

Go to the documentation of this file.

#ifndef EXECUTOR_HPP
#define EXECUTOR_HPP

#include <functional>
#include <vector>
#include <queue>
#include <thread>
#include <mutex>
#include <atomic>
#include <condition_variable>

#include "../error/kallisto_error.hpp"

namespace kallisto {
namespace util {

class Executor {
public:
    static const unsigned int MAXIMUM_NUMBER_THREADS;

    static const unsigned int MINIMUM_NUMBER_THREADS;

    typedef std::function<void()> ExecutorRunnable;

private:
    std::string m_tag;
    std::vector<std::thread> m_threads; //Holds the executor threads
    std::condition_variable m_threads_cv;

    std::queue<ExecutorRunnable> m_runnable_queue; //Holds the executor requests
    std::mutex m_runnable_queue_mutex;

    std::atomic<bool> m_running;  //Signals if executor is still accepting tasks.

    void run(unsigned int i);

    Executor(Executor const&) = delete;
    Executor(Executor&&) = delete;
    void operator=(Executor const&) = delete;
    void operator=(Executor &&) = delete;

public:
    Executor(std::string tag, unsigned int nr_threads);

    ~Executor();

    error::KallistoDetailedResult execute(ExecutorRunnable runnable);

    error::KallistoDetailedResult shutdown();

    error::KallistoDetailedResult shutdownNow();

    void awaitShutdown();
};

} /* namespace util */
} /* namespace kallisto */


#endif // EXECUTOR_HPP