Struct MainSessionExecutor 

pub struct MainSessionExecutor { /* private fields */ }

主会话执行器

在主会话中执行调度任务，任务执行结果直接影响主会话状态。

需求映射

• Requirement 7.7: 主会话执行器实现
• Requirement 7.8: 执行结果返回
• Requirement 7.9: 状态更新

使用场景

适用于需要与用户当前会话交互的任务，如：

• 定时提醒
• 状态报告
• 需要用户响应的任务

示例

use aster::scheduler::executor::{MainSessionExecutor, ExecutionContext};

let executor = MainSessionExecutor::new();
let ctx = ExecutionContext::new();
let result = executor.execute(&job, &ctx).await?;

Implementations

impl MainSessionExecutor

pub fn new() -> Self

创建新的主会话执行器

Trait Implementations

impl Default for MainSessionExecutor

fn default() -> Self

Returns the “default value” for a type.

impl TaskExecutor for MainSessionExecutor

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, job: &'life1 NewScheduledJob, ctx: &'life2 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<ExecutionResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

执行任务

fn cancel<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

取消执行

fn name(&self) -> &str

获取执行器名称