#9 - Added Optional Callbacks for Thread (interfaces in IThread

Author: LK-Simon

src/ESPressio_IThread.hpp

@@ -91,6 +91,9 @@ namespace ESPressio {
                 /// `GetOnDestroying` returns the callback to be invoked when the Thread is being destroyed.
                 virtual std::function<void(IThread*)> GetOnDestroy() = 0;
 
+                /// `GetOnStateChange` returns the callback to be invoked when the Thread's state changes.
+                virtual std::function<void(IThread*, ThreadState, ThreadState)> GetOnStateChange() = 0;
+
             // Setters
 
                 /// `SetCoreID` sets the ID of the Core the Thread should run on.
@@ -126,6 +129,10 @@ namespace ESPressio {
                 /// `SetOnDestroying` sets the callback to be invoked when the Thread is being destroyed.
                 /// The callback function takes `IThread*` and ideally named `sender`.
                 virtual void SetOnDestroy(std::function<void(IThread*)>) = 0;
+
+                /// `SetOnStateChange` sets the callback to be invoked when the Thread's state changes.
+                /// The callback function takes `IThread*` and ideally named `sender`, `ThreadState` for the previous state and `ThreadState` for the new state.
+                virtual void SetOnStateChange(std::function<void(IThread*, ThreadState, ThreadState)>) = 0;
         };
 
     }

src/ESPressio_Thread.hpp

@@ -26,6 +26,7 @@ namespace ESPressio {
 
                 /// `TOnThreadEvent` is a function type that can be used to handle Thread events.
                 using TOnThreadEvent = std::function<void(IThread*)>;
+                using TOnThreadStateChangeEvent = std::function<void(IThread*, ThreadState, ThreadState)>;
 
             // Members
                 uint8_t _threadID; // This is idempotent so doesn't need a `Mutex` wrapper.
@@ -42,6 +43,7 @@ namespace ESPressio {
                 TOnThreadEvent _onPause = nullptr;
                 TOnThreadEvent _onTerminate = nullptr;
                 TOnThreadEvent _onDestroy = nullptr;
+                TOnThreadStateChangeEvent _onStateChange = nullptr;
 
             // Methods
                 void _loop() {
@@ -79,7 +81,9 @@ namespace ESPressio {
             // Setters (Internal)
 
                 void SetThreadState(ThreadState state) {
+                    ThreadState oldState = _threadState.Get();
                     _threadState.Set(state);
+                    if (_onStateChange != nullptr) { _onStateChange(this, oldState, state); }
                 }
             public:
 
@@ -189,6 +193,10 @@ namespace ESPressio {
                     return _onDestroy;
                 }
 
+                std::function<void(IThread*, ThreadState, ThreadState)> GetOnStateChange() {
+                    return _onStateChange;
+                }
+
             // Setters
 
                 void SetCoreID(BaseType_t value) {
@@ -232,6 +240,10 @@ namespace ESPressio {
                 void SetOnDestroy(std::function<void(IThread*)> value) {
                     _onDestroy = value;
                 }
+
+                void SetOnStateChange(std::function<void(IThread*, ThreadState, ThreadState)> value) {
+                    _onStateChange = value;
+                }
         };
 
     }