task_scheduler.h

Go to the documentation of this file.

#pragma once

 
#include <condition_variable>
#include <map>
#include <mutex>
#include <string>
#include <thread>
 
namespace satdump
{
    struct ScheduledTask
    {
        std::shared_ptr<void> evt = nullptr;
        std::string evt_name;
        time_t last_run = 0;
        time_t run_interval = 0;
    };

    class TaskScheduler
    {
    private:
        bool running = true;
        bool needs_update = false;
        std::map<std::string, ScheduledTask> scheduled_tasks;
        std::thread task_thread;
        std::mutex task_mtx;
        std::condition_variable cv;

        void thread_func();
 
    public:
        TaskScheduler();
        ~TaskScheduler();

        template <typename T>
        void add_task(std::string task_name, std::shared_ptr<T> evt, time_t last_run, time_t run_interval)
        {
            // Add Task
            {
                std::lock_guard<std::mutex> lock(task_mtx);
                scheduled_tasks[task_name] = {evt, typeid(T).name(), last_run, run_interval};
                needs_update = true;
            }
 
            // Notify thread
            cv.notify_one();
        }

        void del_task(std::string task_name)
        {
            // Delete Task
            {
                std::lock_guard<std::mutex> lock(task_mtx);
                scheduled_tasks.erase(task_name);
                needs_update = true;
            }
 
            // Notify thread
            cv.notify_one();
        }
    };
} // namespace satdump