fix: docker thead bug

Author: zhayujie

Dockerfile

@@ -19,3 +19,6 @@ ENV CONFIG_PATH=/app/config.yaml
 
 # Set entrypoint
 CMD ["/app/entrypoint.sh"]
+
+# 添加环境变量标识Docker容器环境
+ENV DOCKER_CONTAINER=true

agentmesh/common/utils/loading_indicator.py

@@ -2,12 +2,14 @@
 import time
 import sys
 import itertools
+import os
 
 
 class LoadingIndicator:
     """
     A utility class for displaying a loading animation in the console.
     """
+
     def __init__(self, message="Loading", animation_type="spinner"):
         """
         Initialize the loading indicator.
@@ -19,41 +21,68 @@ def __init__(self, message="Loading", animation_type="spinner"):
         self.animation_type = animation_type
         self.is_running = False
         self.thread = None
-        
+
         # Define different animation styles
         self.animations = {
             "spinner": itertools.cycle(['⠋', '⠙', '⠹', '⠸', '⠼', '⠴', '⠦', '⠧', '⠇', '⠏']),
             "dots": itertools.cycle(['.  ', '.. ', '...', '   ']),
             "bar": itertools.cycle(['[=  ]', '[== ]', '[===]', '[ ==]', '[  =]', '[   ]']),
             "thinking": itertools.cycle(['🧠  ', '🧠. ', '🧠..', '🧠...'])
         }
-        
+
         # Use the specified animation or default to spinner
         self.animation = self.animations.get(animation_type, self.animations["spinner"])
-    
+
+        # Check if we're in a Docker environment
+        self.use_threading = not (os.environ.get("DOCKER_CONTAINER", "").lower() in ("true", "1"))
+
     def _animate(self):
         """The animation function that runs in a separate thread."""
         while self.is_running:
             char = next(self.animation)
             sys.stdout.write(f'\r{char} {self.message}')
             sys.stdout.flush()
             time.sleep(0.1)
-        
+
         # Clear the line when animation stops
         sys.stdout.write('\r' + ' ' * (len(self.message) + 10) + '\r')
         sys.stdout.flush()
-    
+
+    def _animate_simple(self):
+        """A simpler animation that doesn't use threading."""
+        char = next(self.animation)
+        sys.stdout.write(f'\r{char} {self.message}')
+        sys.stdout.flush()
+
     def start(self):
         """Start the loading animation."""
         if not self.is_running:
             self.is_running = True
-            self.thread = threading.Thread(target=self._animate)
-            self.thread.daemon = True
-            self.thread.start()
-    
+
+            # Use threading only if it's enabled
+            if self.use_threading:
+                try:
+                    self.thread = threading.Thread(target=self._animate)
+                    self.thread.daemon = True
+                    self.thread.start()
+                except (RuntimeError, ThreadError):
+                    # If thread creation fails, fall back to simple mode
+                    self._animate_simple()
+            else:
+                # Just show a static indicator without animation
+                sys.stdout.write(f'\r⏳ {self.message}')
+                sys.stdout.flush()
+
     def stop(self):
         """Stop the loading animation."""
         if self.is_running:
             self.is_running = False
-            if self.thread:
-                self.thread.join()
+            if self.thread and self.use_threading:
+                try:
+                    self.thread.join(timeout=0.5)  # Add timeout to prevent hanging
+                except Exception:
+                    pass  # Ignore any errors when stopping
+
+            # Clear the line
+            sys.stdout.write('\r' + ' ' * (len(self.message) + 10) + '\r')
+            sys.stdout.flush()

docker-compose.yml

@@ -8,3 +8,5 @@ services:
       - ./config.yaml:/app/config.yaml
     stdin_open: true  # Enable interactive input
     tty: true         # Allocate a pseudo-TTY
+    environment:
+      - DOCKER_CONTAINER=true