Struct TaskManager 

pub struct TaskManager { /* private fields */ }

任务管理器

负责管理所有任务的生命周期

功能

• 任务注册和管理
• 依赖排序和启动
• 优雅停机
• 状态追踪

示例

use flare_core_runtime::task::TaskManager;
use flare_core_runtime::task::SpawnTask;

let manager = TaskManager::new();

// 添加任务
manager.add_task(Box::new(SpawnTask::new("task-1", async { Ok(()) })));

// 启动所有任务
let (join_set, shutdown_txs) = manager.start_all().await?;

// 等待停机信号
// ...

// 停止所有任务
manager.stop_all(join_set, shutdown_txs).await;

Implementations

impl TaskManager

pub fn new() -> Self

创建新的任务管理器

pub fn with_config(config: RuntimeConfig) -> Self

创建新的任务管理器（带配置）

pub fn add_task(&mut self, task: Box<dyn Task>)

添加任务

pub fn task_count(&self) -> usize

获取任务数量

pub fn state_tracker(&self) -> Arc<StateTracker>

获取状态追踪器

pub async fn start_all( &mut self, ) -> Result<(JoinSet<TaskResult>, Vec<Sender<()>>), RuntimeError>

启动所有任务

返回

• join_set - 任务 JoinSet，用于等待任务完成
• shutdown_txs - shutdown 信号发送器列表

错误

• 循环依赖
• 缺失依赖

pub async fn stop_all( &self, join_set: JoinSet<TaskResult>, shutdown_txs: Vec<Sender<()>>, )

停止所有任务

参数

• join_set - 任务 JoinSet
• shutdown_txs - shutdown 信号发送器列表

pub async fn wait_for_ready(&self) -> Result<(), RuntimeError>

等待所有任务就绪

Trait Implementations

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.