-
Notifications
You must be signed in to change notification settings - Fork 0
/
Scheduler.h
50 lines (42 loc) · 1.17 KB
/
Scheduler.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
/*
* File: Scheduler.h
* Author: jonathan.fast
*
* Created on April 1, 2015, 11:58 AM
*/
#ifndef SCHEDULER_H
#define SCHEDULER_H
#include <vector>
#include <functional>
#include <thread>
#include <future>
#include <chrono>
#include "Logger.h"
class TaskResult {
public:
std::chrono::time_point<std::chrono::system_clock> finished_at;
uint64_t result_code;
uint64_t schedule_id;
};
class Schedule {
public:
Schedule() {
this->last_run = std::chrono::system_clock::now() - std::chrono::hours(24);
}
uint64_t schedule_id;
std::chrono::time_point<std::chrono::system_clock> last_run;
std::chrono::duration<double> run_every;
std::string task_name;
std::function<std::shared_ptr<TaskResult>(uint64_t, std::shared_ptr<Logger>)> runner;
};
class Scheduler {
public:
Scheduler(std::vector<std::shared_ptr<Schedule>>& schedules, std::shared_ptr<Logger> logger);
virtual ~Scheduler();
void run(bool sleep = true);
private:
std::vector<std::shared_ptr<Schedule>> schedules;
std::vector<std::shared_ptr<std::promise<std::shared_ptr<TaskResult>>>> promises;
std::shared_ptr<Logger> logger;
};
#endif /* SCHEDULER_H */