forked from tlextrait/ArduinoThread
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathThread.cpp
More file actions
94 lines (75 loc) · 1.85 KB
/
Thread.cpp
File metadata and controls
94 lines (75 loc) · 1.85 KB
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
#include "Thread.h"
template <typename Arg>
Thread<Arg>::Thread(void (*callback)(), long _interval){
enabled = true;
_callbackArgumentSet = false;
onRun(callback);
_cached_next_run = 0;
last_run = 0;
ThreadID = (int)this;
#ifdef USE_THREAD_NAMES
ThreadName = "Thread ";
ThreadName = ThreadName + ThreadID;
#endif
setInterval(_interval);
}
template <typename Arg>
Thread<Arg>::Thread(void (*callback)(Arg), Arg arg, long _interval){
enabled = true;
_callbackArgument = arg;
_callbackArgumentSet = true;
onRun(callback);
_cached_next_run = 0;
last_run = 0;
ThreadID = (int)this;
#ifdef USE_THREAD_NAMES
ThreadName = "Thread ";
ThreadName = ThreadName + ThreadID;
#endif
setInterval(_interval);
}
template <typename Arg>
void Thread<Arg>::hasRun(long time){
// If less than 0, than get current ticks
if(time < 0)
time = millis();
// Saves last_run
last_run = time;
// Cache next run
_cached_next_run = last_run + interval;
}
template <typename Arg>
void Thread<Arg>::setInterval(long _interval){
// Filter intervals less than 0
interval = (_interval < 0? 0: _interval);
// Cache the next run based on the last_run
_cached_next_run = last_run + interval;
}
template <typename Arg>
bool Thread<Arg>::shouldRun(long time){
// If less than 0, then get current ticks
if(time < 0)
time = millis();
// Exceeded the time limit, AND is enabled? Then should run...
return ((time >= _cached_next_run) && enabled);
}
template <typename Arg>
void Thread<Arg>::onRun(void (*callback)(void)){
_onRun = callback;
}
template <typename Arg>
void Thread<Arg>::onRun(void (*callback)(Arg)){
_onRunArg = callback;
}
template <typename Arg>
void Thread<Arg>::run(){
if(_callbackArgumentSet){
if(_onRunArg != NULL)
_onRunArg(this->_callbackArgument);
}else{
if(_onRun != NULL)
_onRun();
}
// Update last_run and _cached_next_run
hasRun();
}