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_ */