TaskRunner.h

 
#ifndef GPGFRONTEND_TASKRUNNER_H
#define GPGFRONTEND_TASKRUNNER_H
 
#include <cstddef>
#include <mutex>
#include <queue>
 
#include "core/GpgFrontendCore.h"
 
namespace GpgFrontend::Thread {
 
class Task;
 
class GPGFRONTEND_CORE_EXPORT TaskRunner : public QThread {
  Q_OBJECT
 public:
  TaskRunner();
 
  virtual ~TaskRunner() override;
 
  [[noreturn]] void run() override;
 
 public slots:
 
  void PostTask(Task* task);
 
  void PostScheduleTask(Task* task, size_t seconds);
 
 private:
  std::queue<Task*> tasks;                      
  std::map<std::string, Task*> pending_tasks_;  
  std::mutex tasks_mutex_;                      
  QThreadPool thread_pool_{this};               
 
  void unregister_finished_task(std::string);
};
}  // namespace GpgFrontend::Thread
 
#endif  // GPGFRONTEND_TASKRUNNER_H