threadable.hpp

Go to the documentation of this file.

 
/*****************************************************************************
** Ifdefs
*****************************************************************************/
 
#ifndef ECL_THREADS_THREADABLE_POS_HPP_
#define ECL_THREADS_THREADABLE_POS_HPP_
 
/*****************************************************************************
** Platform Check
*****************************************************************************/
 
#include <ecl/config/ecl.hpp>
#if defined(ECL_IS_POSIX)
 
/*****************************************************************************
** Includes
*****************************************************************************/
 
#include <ecl/utilities/parameter.hpp>
#include <ecl/config/macros.hpp>
#include "thread.hpp"
#include "priority.hpp"
 
/*****************************************************************************
** Namespaces
*****************************************************************************/
 
namespace ecl {
 
/*****************************************************************************
** Interface [Threadable]
*****************************************************************************/
class ECL_PUBLIC Threadable {
public:
        virtual ~Threadable() {}
 
        bool start(const Priority &priority = DefaultPriority) {
                if ( isRunning() ) { return false; }
                isRunning(true); // This is not ideal, as it's not perfectly atomic (i.e. someone can query isRunning before this gets set).
                Thread thread(&Threadable::executeThreadFunction,*this, priority);
                return true;
        }
        Parameter<bool> isRunning;
 
protected:
        Threadable() : isRunning(false) {}
 
        virtual void runnable() = 0;
 
private:
        void executeThreadFunction() {
                runnable();
                isRunning(false);
        }
};
 
} // namespace ecl
 
#endif /* ECL_IS_POSIX */
#endif /* ECL_THREADS_THREADABLE_POS_HPP_ */