start -> activate

hardware_interface/include/hardware_interface/async_components.hpp

@@ -59,7 +59,7 @@ class AsyncComponentThread
     }
   }
 
-  void start() { write_and_read_ = std::thread(&AsyncComponentThread::write_and_read, this); }
+  void activate() { write_and_read_ = std::thread(&AsyncComponentThread::write_and_read, this); }
 
   void write_and_read()
   {

hardware_interface/src/resource_manager.cpp

@@ -305,6 +305,29 @@ class ResourceStorage
 
     if (result)
     {
+      if constexpr (std::is_same_v<hardware_interface::Actuator, HardwareT>)
+      {
+        if (async_actuator_threads_.find(hardware.get_name()) != async_actuator_threads_.end())
+        {
+          async_actuator_threads_.at(hardware.get_name()).activate();
+        }
+      }
+
+      if constexpr (std::is_same_v<hardware_interface::System, HardwareT>)
+      {
+        if (async_system_threads_.find(hardware.get_name()) != async_system_threads_.end())
+        {
+          async_system_threads_.at(hardware.get_name()).activate();
+        }
+      }
+
+      if constexpr (std::is_same_v<hardware_interface::Sensor, HardwareT>)
+      {
+        if (async_sensor_threads_.find(hardware.get_name()) != async_sensor_threads_.end())
+        {
+          async_sensor_threads_.at(hardware.get_name()).activate();
+        }
+      }
       // TODO(destogl): make all command interfaces available (currently are all available)
     }
 
@@ -1304,21 +1327,6 @@ void ResourceManager::allocate_threads_for_async_components()
         std::forward_as_tuple(component, cm_update_rate_, clock_interface_));
     }
   }
-
-  for (auto & thread : resource_storage_->async_actuator_threads_)
-  {
-    thread.second.start();
-  }
-
-  for (auto & thread : resource_storage_->async_system_threads_)
-  {
-    thread.second.start();
-  }
-
-  for (auto & thread : resource_storage_->async_sensor_threads_)
-  {
-    thread.second.start();
-  }
 }
 
 // BEGIN: private methods

joint_limits_interface/test/joint_limits_urdf_test.cpp

@@ -20,7 +20,6 @@
 
 #include <joint_limits_interface/joint_limits_urdf.hpp>
 
-
 class JointLimitsUrdfTest : public ::testing::Test
 {
 public: