feat: add real-time SubAgent task list and activity monitoring

- Add SubAgentInfo struct with metadata (id, type, description, state, timestamps)
- Add SubAgentActivity enum (Idle, CallingTool, RequestingLlm, WaitingForControl)
- Add orchestrator.list_subagents() - get all SubAgent info with current activity
- Add orchestrator.get_subagent_info(id) - get specific SubAgent details
- Add orchestrator.get_active_activities() - get all active SubAgent activities
- Add orchestrator.get_handle(id) - get SubAgent handle for direct control
- Update SubAgentHandle to track config, created_at, and activity
- Update SubAgentWrapper to track and update current activity
- Add orchestrator_monitoring.rs example demonstrating real-time monitoring
- Update architecture docs with monitoring API and use cases

Author: hikejs

Cargo.lock

@@ -0,0 +1,127 @@
+//! 演示主智能体实时监控子智能体任务列表和活动
+//!
+//! 运行: cargo run --example orchestrator_monitoring
+
+use a3s_code_core::orchestrator::{AgentOrchestrator, SubAgentConfig};
+use std::time::Duration;
+
+#[tokio::main]
+async fn main() -> anyhow::Result<()> {
+    println!("=== AgentTeam 实时监控演示 ===\n");
+
+    // 1. 创建编排器
+    let orchestrator = AgentOrchestrator::new_memory();
+    println!("✓ 创建 AgentOrchestrator\n");
+
+    // 2. 启动多个子智能体
+    println!("启动 3 个子智能体...");
+
+    let config1 = SubAgentConfig::new("explore", "Search for Python files")
+        .with_description("探索代码库，查找所有 Python 文件")
+        .with_max_steps(10);
+
+    let config2 = SubAgentConfig::new("analyze", "Analyze code quality")
+        .with_description("分析代码质量和潜在问题")
+        .with_max_steps(15);
+
+    let config3 = SubAgentConfig::new("refactor", "Refactor legacy code")
+        .with_description("重构遗留代码，提高可维护性")
+        .with_max_steps(20);
+
+    let handle1 = orchestrator.spawn_subagent(config1).await?;
+    let handle2 = orchestrator.spawn_subagent(config2).await?;
+    let handle3 = orchestrator.spawn_subagent(config3).await?;
+
+    println!("✓ 启动了 3 个子智能体\n");
+
+    // 3. 实时监控任务列表
+    println!("=== 实时监控任务列表 ===\n");
+
+    for i in 1..=5 {
+        println!("--- 监控快照 #{} ---", i);
+
+        // 获取所有子智能体信息
+        let subagents = orchestrator.list_subagents().await;
+        println!("活跃子智能体数量: {}", orchestrator.active_count().await);
+        println!();
+
+        for info in subagents {
+            println!("SubAgent: {}", info.id);
+            println!("  类型: {}", info.agent_type);
+            println!("  描述: {}", info.description);
+            println!("  状态: {}", info.state);
+            if let Some(activity) = info.current_activity {
+                println!("  当前活动: {:?}", activity);
+            }
+            println!();
+        }
+
+        // 获取所有活跃子智能体的当前活动
+        let activities = orchestrator.get_active_activities().await;
+        if !activities.is_empty() {
+            println!("活跃子智能体的实时活动:");
+            for (id, activity) in activities {
+                println!("  {}: {:?}", id, activity);
+            }
+            println!();
+        }
+
+        tokio::time::sleep(Duration::from_millis(500)).await;
+    }
+
+    // 4. 查询特定子智能体的详细信息
+    println!("=== 查询特定子智能体详情 ===\n");
+
+    if let Some(info) = orchestrator.get_subagent_info(&handle1.id).await {
+        println!("SubAgent 详情:");
+        println!("  ID: {}", info.id);
+        println!("  类型: {}", info.agent_type);
+        println!("  描述: {}", info.description);
+        println!("  状态: {}", info.state);
+        println!("  创建时间: {}", info.created_at);
+        println!("  更新时间: {}", info.updated_at);
+        if let Some(activity) = info.current_activity {
+            println!("  当前活动: {:?}", activity);
+        }
+        println!();
+    }
+
+    // 5. 动态控制子智能体
+    println!("=== 动态控制演示 ===\n");
+
+    println!("暂停 subagent-1...");
+    orchestrator.pause_subagent(&handle1.id).await?;
+    tokio::time::sleep(Duration::from_millis(200)).await;
+
+    // 查看状态变化
+    if let Some(info) = orchestrator.get_subagent_info(&handle1.id).await {
+        println!("  状态: {} (应该是 Paused)", info.state);
+        if let Some(activity) = info.current_activity {
+            println!("  活动: {:?}", activity);
+        }
+    }
+    println!();
+
+    println!("恢复 subagent-1...");
+    orchestrator.resume_subagent(&handle1.id).await?;
+    tokio::time::sleep(Duration::from_millis(200)).await;
+
+    if let Some(info) = orchestrator.get_subagent_info(&handle1.id).await {
+        println!("  状态: {} (应该是 Running)", info.state);
+    }
+    println!();
+
+    // 6. 等待所有完成
+    println!("等待所有子智能体完成...");
+    orchestrator.wait_all().await?;
+
+    println!("\n=== 最终状态 ===\n");
+    let final_states = orchestrator.get_all_states().await;
+    for (id, state) in final_states {
+        println!("{}: {:?}", id, state);
+    }
+
+    println!("\n✓ 演示完成");
+
+    Ok(())
+}

core/examples/orchestrator_monitoring.rs

@@ -60,6 +60,58 @@ pub struct SubAgentConfig {
     pub metadata: serde_json::Value,
 }
 
+/// SubAgent 信息（元数据）
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct SubAgentInfo {
+    /// SubAgent ID
+    pub id: String,
+
+    /// Agent 类型
+    pub agent_type: String,
+
+    /// 任务描述
+    pub description: String,
+
+    /// 当前状态
+    pub state: String,
+
+    /// 父 SubAgent ID
+    pub parent_id: Option<String>,
+
+    /// 创建时间（Unix 时间戳，毫秒）
+    pub created_at: u64,
+
+    /// 最后更新时间（Unix 时间戳，毫秒）
+    pub updated_at: u64,
+
+    /// 当前活动
+    pub current_activity: Option<SubAgentActivity>,
+}
+
+/// SubAgent 当前活动
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(tag = "type", rename_all = "snake_case")]
+pub enum SubAgentActivity {
+    /// 空闲
+    Idle,
+
+    /// 正在调用工具
+    CallingTool {
+        tool_name: String,
+        args: serde_json::Value,
+    },
+
+    /// 正在请求 LLM
+    RequestingLlm {
+        message_count: usize,
+    },
+
+    /// 正在等待控制信号
+    WaitingForControl {
+        reason: String,
+    },
+}
+
 impl SubAgentConfig {
     /// 创建新的 SubAgent 配置
     pub fn new(agent_type: impl Into<String>, prompt: impl Into<String>) -> Self {

core/src/orchestrator/config.rs

@@ -1,7 +1,7 @@
 //! SubAgent 句柄
 
 use crate::error::Result;
-use crate::orchestrator::{ControlSignal, SubAgentState};
+use crate::orchestrator::{ControlSignal, SubAgentActivity, SubAgentConfig, SubAgentState};
 use std::sync::Arc;
 use tokio::sync::RwLock;
 
@@ -13,12 +13,21 @@ pub struct SubAgentHandle {
     /// SubAgent ID
     pub id: String,
 
+    /// SubAgent 配置
+    pub(crate) config: SubAgentConfig,
+
+    /// 创建时间（Unix 时间戳，毫秒）
+    pub(crate) created_at: u64,
+
     /// 控制信号发送器
     control_tx: tokio::sync::mpsc::Sender<ControlSignal>,
 
     /// 状态
     state: Arc<RwLock<SubAgentState>>,
 
+    /// 当前活动
+    pub(crate) activity: Arc<RwLock<SubAgentActivity>>,
+
     /// 任务句柄
     task_handle: Arc<tokio::task::JoinHandle<Result<String>>>,
 }
@@ -27,14 +36,22 @@ impl SubAgentHandle {
     /// 创建新的句柄
     pub(crate) fn new(
         id: String,
+        config: SubAgentConfig,
         control_tx: tokio::sync::mpsc::Sender<ControlSignal>,
         state: Arc<RwLock<SubAgentState>>,
+        activity: Arc<RwLock<SubAgentActivity>>,
         task_handle: tokio::task::JoinHandle<Result<String>>,
     ) -> Self {
         Self {
             id,
+            config,
+            created_at: std::time::SystemTime::now()
+                .duration_since(std::time::UNIX_EPOCH)
+                .unwrap()
+                .as_millis() as u64,
             control_tx,
             state,
+            activity,
             task_handle: Arc::new(task_handle),
         }
     }
@@ -55,6 +72,21 @@ impl SubAgentHandle {
         self.state.read().await.clone()
     }
 
+    /// 获取当前活动
+    pub async fn activity(&self) -> SubAgentActivity {
+        self.activity.read().await.clone()
+    }
+
+    /// 获取配置
+    pub fn config(&self) -> &SubAgentConfig {
+        &self.config
+    }
+
+    /// 获取创建时间
+    pub fn created_at(&self) -> u64 {
+        self.created_at
+    }
+
     /// 发送控制信号
     pub async fn send_control(&self, signal: ControlSignal) -> Result<()> {
         self.control_tx

core/src/orchestrator/handle.rs

@@ -65,7 +65,7 @@ mod wrapper;
 #[cfg(test)]
 mod tests;
 
-pub use config::{OrchestratorConfig, SubAgentConfig};
+pub use config::{OrchestratorConfig, SubAgentActivity, SubAgentConfig, SubAgentInfo};
 pub use control::ControlSignal;
 pub use events::{OrchestratorEvent, SubAgentEventPayload};
 pub use handle::SubAgentHandle;