threadbaseclass.h

Go to the documentation of this file.

/*****************************************
 * This file is documented for Doxygen.
 * If you modify this file please update
 * the comments so that Doxygen will still
 * be able to work.
 ****************************************/
#ifndef THREADBASECLASS_H
#define THREADBASECLASS_H

#include <baseclass.h>
#include <threadstate.h>
#include <workstate.h>
#include <thread>
#include <mutex>
#include <string>
#include <vector>
#include <map>
#include <ctime>

namespace glass3 {
namespace util {
class ThreadBaseClass : public util::BaseClass {
 public:
    ThreadBaseClass();

    ThreadBaseClass(std::string threadName, int sleepTimeMS = 100,
                    int numThreads = 1, int checkInterval = 300);

    ~ThreadBaseClass();

    virtual bool start();

    virtual bool stop();

    int getNumThreads();

    void setNumThreads(int numThreads);

    void setThreadHealth(bool health = true);

    virtual bool healthCheck();

    void setSleepTime(int sleepTimeMS);

    int getSleepTime();

    glass3::util::ThreadState getWorkThreadsState();

    void setHealthCheckInterval(int interval);

    int getHealthCheckInterval();

    bool getTerminate();

    const std::string& getThreadName();

    std::time_t getAllLastHealthy(size_t * pThreadId);

    virtual glass3::util::WorkState work() = 0;

 protected:
    void setWorkThreadsState(glass3::util::ThreadState state);

    void workLoop();

    void setLastHealthy(std::time_t now);

    std::vector<std::thread> m_WorkThreads;

    std::map<std::thread::id, std::atomic<int>> m_ThreadHealthMap;

 private:
    std::string m_sThreadName;

    std::atomic<int> m_iHealthCheckInterval;

    std::atomic<int> m_iNumThreads;

    std::atomic<ThreadState> m_WorkThreadsState;

    std::atomic<int> m_iSleepTimeMS;

    bool m_bTerminate;

    // constants
    static const int k_iHeathCheckIntervalDefault = 30;

    static const int k_iSleepTimeDefault = 100;

    static const int k_iNumThreadsDefault = 10;
};
}  // namespace util
}  // namespace glass3
#endif  // THREADBASECLASS_H