threadpool.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 THREADPOOL_H
#define THREADPOOL_H

#include <baseclass.h>
#include <threadbaseclass.h>
#include <threadstate.h>
#include <thread>
#include <mutex>
#include <queue>
#include <ctime>
#include <string>

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

    explicit ThreadPool(std::string poolName, int numThreads = 5,
                        int sleepTime = 100, int checkInterval = 300);

    ~ThreadPool();

    void addJob(std::function<void()> newJob);

    int getJobQueueSize();

    glass3::util::WorkState work() override;

 private:
    std::queue<std::function<void()>> m_JobQueue;

    std::mutex & getMutex();

    std::mutex m_Mutex;
};
}  // namespace util
}  // namespace glass3
#endif  // THREADPOOL_H