fix: join execute thread on destruction

aica-technology · Oct 9, 2024 · 16a18ea · 16a18ea
1 parent c749a2a
commit 16a18ea
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/source/modulo_components/include/modulo_components/Component.hpp b/source/modulo_components/include/modulo_components/Component.hpp
@@ -32,9 +32,9 @@ class Component : public rclcpp::Node, public ComponentInterface {
   explicit Component(const rclcpp::NodeOptions& node_options, const std::string& fallback_name = "Component");
 
   /**
-   * @brief Virtual default destructor.
+   * @brief Destructor that joins the thread if necessary.
    */
-  virtual ~Component() = default;
+  virtual ~Component();
 
 protected:
   /**

diff --git a/source/modulo_components/src/Component.cpp b/source/modulo_components/src/Component.cpp
@@ -18,6 +18,12 @@ Component::Component(const NodeOptions& node_options, const std::string& fallbac
   this->add_predicate("in_error_state", false);
 }
 
+Component::~Component() {
+  if (this->execute_thread_.joinable()) {
+    this->execute_thread_.join();
+  }
+}
+
 void Component::step() {
   try {
     this->evaluate_periodic_callbacks();