Struct SpawnTask 

pub struct SpawnTask { /* private fields */ }

Spawn 任务

用于包装已经构建好的 Future（例如 gRPC server） 用户可以在 service 层构建好 Future，然后通过 runtime 管理

特性

• 支持依赖声明
• 支持 shutdown 信号
• 支持优先级设置
• 支持关键任务标记

示例

不需要 shutdown 的任务

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::new("my-task", async {
    // 任务逻辑
    Ok(())
});

需要 shutdown 的任务

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::with_shutdown("my-grpc", |shutdown_rx| {
    async move {
        // 使用 shutdown_rx 实现优雅停机
        let _ = shutdown_rx.await;
        Ok(())
    }
});

带依赖的任务

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::new("task-b", async { Ok(()) })
    .with_dependencies(vec!["task-a".to_string()])
    .with_priority(10)
    .with_critical(true);

Implementations

impl SpawnTask

pub fn new<Fut>(name: impl Into<String>, future: Fut) -> Self

where Fut: Future<Output = TaskResult> + Send + 'static,

创建新的 spawn 任务（不需要 shutdown_rx）

参数

• name - 任务名称
• future - 要运行的 Future（不依赖 shutdown_rx）

示例

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::new("my-task", async {
    // 任务逻辑
    Ok(())
});

pub fn with_shutdown<F, Fut>(name: impl Into<String>, future_fn: F) -> Self

where F: FnOnce(Receiver<()>) -> Fut + Send + 'static, Fut: Future<Output = TaskResult> + Send + 'static,

创建新的 spawn 任务（需要 shutdown_rx）

参数

• name - 任务名称
• future_fn - 闭包，接收 shutdown_rx，返回 Future

示例

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::with_shutdown("my-task", |shutdown_rx| {
    async move {
        // 使用 shutdown_rx
        let _ = shutdown_rx.await;
        Ok(())
    }
});

pub fn with_dependencies(self, deps: Vec<String>) -> Self

设置任务依赖

参数

• deps - 依赖的任务名称列表

示例

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::new("task-b", async { Ok(()) })
    .with_dependencies(vec!["task-a".to_string()]);

pub fn with_priority(self, priority: i32) -> Self

设置任务优先级

参数

• priority - 优先级（数值越大优先级越高）

示例

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::new("my-task", async { Ok(()) })
    .with_priority(10);

pub fn with_critical(self, critical: bool) -> Self

设置是否为关键任务

参数

• critical - 是否为关键任务

示例

use flare_core_runtime::task::SpawnTask;

let task = SpawnTask::new("my-task", async { Ok(()) })
    .with_critical(true);

Trait Implementations

impl Task for SpawnTask

fn name(&self) -> &str

获取任务名称

fn dependencies(&self) -> Vec<String>

获取任务依赖

fn run( self: Box<Self>, shutdown_rx: Receiver<()>, ) -> Pin<Box<dyn Future<Output = TaskResult> + Send>>

运行任务

fn priority(&self) -> i32

任务优先级 (用于启动顺序调整)

fn is_critical(&self) -> bool

是否关键任务 (失败时触发运行时停机)

fn ready_check(&self) -> Pin<Box<dyn Future<Output = TaskResult> + Send + '_>>

就绪检查 (可选)

fn initial_state(&self) -> TaskState

获取初始状态