scopedparallelexecutor.h

// Copyright (C) 2008,2009,2010 by Philipp Münzel. All rights reserved.
// Released under the terms of the license described in license.txt

#ifndef SCOPEDPARALLELEXECUTOR_H
#define SCOPEDPARALLELEXECUTOR_H

#include "dllexport.h"

#include <boost/thread.hpp>
#include <boost/function.hpp>
#include <boost/asio.hpp>

namespace SCS {

class DLL_PUBLIC ScopedParallelExecutor
{
public:
    ScopedParallelExecutor();

    ScopedParallelExecutor(boost::function<void()> run_function, long run_interval_ms);

    ~ScopedParallelExecutor();

    void setCallback(boost::function<void()> run_function);

    void setRunInterval(long milliseconds);

    static void delay(int seconds);

private:
    void runFunction();
    void runIOService();

private:
    boost::function<void()> m_run_function;
    long m_run_interval_ms;
    boost::asio::io_service m_io_service;
    std::auto_ptr<boost::asio::io_service::work> m_work;
    boost::thread m_thread;
    boost::asio::deadline_timer m_timer;
    bool m_stop;
};
}
#endif // SCOPEDPARALLELEXECUTOR_H