feat: add osal/threadx/EventDispatcherThreadX (#637)

* feat: add osal/threadx/EventDispatcherThreadX

* Process review comments

osal/threadx/CMakeLists.txt

@@ -23,7 +23,14 @@ target_compile_definitions(threadx PUBLIC
     "TX_SINGLE_MODE_NON_SECURE=1"
 )
 
-add_library(osal.threadx_osal ${EMIL_EXCLUDE_FROM_ALL} STATIC Osal.cpp)
+add_library(osal.threadx_osal ${EMIL_EXCLUDE_FROM_ALL} STATIC)
+
+target_sources(osal.threadx_osal PRIVATE
+    Osal.cpp
+    EventDispatcherThreadX.cpp
+    EventDispatcherThreadX.hpp
+)
+
 target_link_libraries(osal.threadx_osal PUBLIC infra.util threadx)
 
 if (TARGET_BUILD_UNIX OR TARGET_BUILD_OSX)

osal/threadx/EventDispatcherThreadX.cpp

@@ -0,0 +1,28 @@
+#include "osal/threadx/EventDispatcherThreadX.hpp"
+
+namespace hal
+{
+    constexpr static ULONG Execute{ 0x01 };
+
+    void EventDispatcherThreadXWorker::RequestExecution()
+    {
+        if (tx_event_flags_set(&flags, Execute, TX_OR) != TX_SUCCESS)
+            std::abort();
+    }
+
+    void EventDispatcherThreadXWorker::Idle()
+    {
+        ULONG events;
+        if (tx_event_flags_get(&flags, Execute, TX_OR_CLEAR, &events, TX_WAIT_FOREVER) != TX_SUCCESS)
+            std::abort();
+    }
+
+    TX_EVENT_FLAGS_GROUP EventDispatcherThreadXWorker::init()
+    {
+        TX_EVENT_FLAGS_GROUP flags{};
+        if (tx_event_flags_create(&flags, const_cast<char*>("")) != TX_SUCCESS)
+            std::abort();
+
+        return flags;
+    }
+}

osal/threadx/EventDispatcherThreadX.hpp

@@ -0,0 +1,27 @@
+#ifndef OSAL_EVENT_DISPATCHER_THREADX_HPP
+#define OSAL_EVENT_DISPATCHER_THREADX_HPP
+
+#include "infra/event/EventDispatcherWithWeakPtr.hpp"
+#include "tx_api.h"
+
+namespace hal
+{
+    class EventDispatcherThreadXWorker
+        : public infra::EventDispatcherWithWeakPtrWorker
+    {
+    public:
+        using EventDispatcherWithWeakPtrWorker::EventDispatcherWithWeakPtrWorker;
+
+        void RequestExecution() override;
+        void Idle() override;
+
+    private:
+        TX_EVENT_FLAGS_GROUP flags{ init() };
+
+        static TX_EVENT_FLAGS_GROUP init();
+    };
+
+    using EventDispatcherThreadX = infra::EventDispatcherWithWeakPtrConnector<EventDispatcherThreadXWorker>;
+}
+
+#endif