diff --git a/app.py b/app.py index d1bdde44..e4713dd1 100644 --- a/app.py +++ b/app.py @@ -9,10 +9,10 @@ from plugins.plugin_manager import PluginManager -# 启动通道 +# Start channel def start_process(channel_type, config_path): try: - # 若为多进程启动,子进程无法直接访问主进程的内存空间,重新创建config类 + # For multi-process startup, child processes cannot directly access parent process memory space, recreate config class config.load_config(config_path) model_type = config.conf().get("model").get("type") log.info("[MultiChannel] Start up {} on {}", model_type, channel_type) @@ -32,25 +32,25 @@ def main(): channel_type = config.conf().get("channel").get("type") PluginManager() - # 1.单个字符串格式配置时,直接启动 + # 1. For single string config format, start directly if not isinstance(channel_type, list): start_process(channel_type, args.config) exit(0) - # 2.单通道列表配置时,直接启动 + # 2. For single channel list config, start directly if len(channel_type) == 1: start_process(channel_type[0], args.config) exit(0) - # 3.多通道配置时,进程池启动 - # 使用主进程启动终端通道 + # 3. For multi-channel config, start with process pool + # Use main process to start terminal channel if const.TERMINAL in channel_type: index = channel_type.index(const.TERMINAL) terminal = channel_type.pop(index) else: terminal = None - # 使用进程池启动其他通道子进程 + # Use process pool to start other channel subprocesses pool = Pool(len(channel_type)) for type_item in channel_type: log.info("[INIT] Start up: {} on {}", model_type, type_item) @@ -59,7 +59,7 @@ def main(): if terminal: start_process(terminal, args.config) - # 等待池中所有进程执行完毕 + # Wait for all processes in the pool to complete pool.close() pool.join() except Exception as e: