feat: スレッドのロックを追加し、接続スレッドの管理を改善

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "adf_core_python"
-version = "0.2.5"
+version = "0.2.6"
 description = "Agent Development Framework for Python"
 readme = "README.md"
 authors = [

src/adf_core_python/core/launcher/agent_launcher.py

@@ -89,20 +89,30 @@ def launch(self) -> None:
 
       gateway_launcher = GatewayLauncher(gateway_host, gateway_port, self.logger)
 
+    lock = threading.Lock()
     connector_thread_list: list[threading.Thread] = []
+
     for connector in self.connectors:
       threads = connector.connect(
         component_launcher, gateway_launcher, self.config, self.loader
       )
-      self.agent_thread_list.extend(threads)
 
-      def connect() -> None:
+      for thread in threads:
+        thread.daemon = True
+
+      with lock:
+        self.agent_thread_list.extend(threads)
+
+      def start_connector_threads(
+        threads: dict[threading.Thread, threading.Event],
+      ) -> None:
         for thread, event in threads.items():
-          thread.daemon = True
           thread.start()
           event.wait(5)
 
-      connector_thread = threading.Thread(target=connect)
+      connector_thread = threading.Thread(
+        target=start_connector_threads, args=(threads,)
+      )
       connector_thread_list.append(connector_thread)
       connector_thread.start()