Struct StateTracker 

pub struct StateTracker { /* private fields */ }

状态追踪器

实时追踪所有任务的状态，支持事件订阅

特性

• 线程安全（使用 Arc<RwLock>）
• 支持事件订阅（使用 broadcast 通道）
• 记录状态变更时间
• 计算运行时长

示例

use flare_core_runtime::state::StateTracker;
use flare_core_runtime::task::TaskState;

#[tokio::main]
async fn main() {
let tracker = StateTracker::new();

// 注册任务
tracker.register_task("task-1", TaskState::Pending).await;

// 更新状态
tracker.update_state("task-1", TaskState::Starting).await;
tracker.update_state("task-1", TaskState::Running).await;

// 获取状态
let info = tracker.get_state("task-1").await.unwrap();
assert_eq!(info.state, TaskState::Running);
}

Implementations

impl StateTracker

pub fn new() -> Self

创建新的状态追踪器

pub fn with_capacity(capacity: usize) -> Self

创建新的状态追踪器（指定事件缓冲区大小）

pub async fn register_task( &self, name: impl Into<String>, initial_state: TaskState, )

注册任务

pub async fn update_state( &self, name: &str, new_state: TaskState, ) -> Option<StateEvent>

更新任务状态

返回

返回状态事件（如果状态变更成功）

pub async fn update_state_with_error( &self, name: &str, new_state: TaskState, error: impl Into<String>, ) -> Option<StateEvent>

更新任务状态（带错误信息）

pub async fn get_state(&self, name: &str) -> Option<TaskStateInfo>

获取任务状态

pub async fn get_all_states(&self) -> Vec<TaskStateInfo>

获取所有任务状态

pub fn subscribe(&self) -> Receiver<StateEvent>

订阅状态事件

pub async fn all_ready(&self) -> bool

检查所有任务是否都已就绪

pub async fn has_failures(&self) -> bool

检查是否有任务失败

pub async fn get_failed_tasks(&self) -> Vec<String>

获取失败的任务

pub async fn running_count(&self) -> usize

获取运行中的任务数量

Trait Implementations

impl Clone for StateTracker

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for StateTracker

fn default() -> Self

Returns the “default value” for a type.