D:/Home/Programs/iSpike/include/iSpike/ISpikeThread.hpp

Go to the documentation of this file.

#ifndef ISPIKETHREAD_HPP
#define ISPIKETHREAD_HPP

//iSpike includes
#include <iSpike/Log/Log.hpp>

//Other includes
#include <string>
#include <boost/thread.hpp>
#include <boost/smart_ptr.hpp>
using namespace std;

namespace ispike {

        class ISpikeThread {

                public:
                        ISpikeThread(){
                                errorFlag = false;
                                running = false;
                                stopRequested = false;
                                errorMessage = "";
                        }

                        virtual ~ISpikeThread(){}

                        void clearError(){ errorFlag = false; errorMessage = ""; }

                        string getErrorMessage() { return errorMessage; }

                        bool isError() { return errorFlag; }

                        bool isRunning() { return running; }

                        bool isStopRequested() { return stopRequested; }

                        void requestStop() { stopRequested = true; }

                        void setError(string errorMsg) { errorFlag = true; errorMessage = errorMsg; LOG(LOG_CRITICAL)<<"Thread error: "<< errorMsg; }

                        void setRunning(bool running) { this->running = running; stopRequested = !running; }

                        virtual void start() = 0;


                protected:
                        virtual void workerFunction() = 0;

                        boost::shared_ptr<boost::thread> getThreadPointer() const { return threadPointer; }

                        void setThreadPointer(boost::shared_ptr<boost::thread> threadPointer) { this->threadPointer = threadPointer; }

                        boost::mutex threadMutex;


                private:
                        bool errorFlag;

                        string errorMessage;

                        bool running;

                        bool stopRequested;

                        boost::shared_ptr<boost::thread> threadPointer;

        };

}

#endif//ISPIKETHREAD_HPP