Struct IsolatedSessionExecutor 

pub struct IsolatedSessionExecutor { /* private fields */ }

隔离会话执行器

在独立的隔离会话中执行调度任务，不影响主会话状态。 执行完成后可以将结果回传到主会话。

需求映射

• Requirement 4.4: 隔离会话创建
• Requirement 4.5: 隔离会话执行
• Requirement 4.6: 结果回传逻辑
• Requirement 4.7: 输出截断

使用场景

适用于需要独立执行的任务，如：

• 长时间运行的任务
• 可能产生大量输出的任务
• 不希望影响主会话状态的任务

示例

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

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

Implementations

impl IsolatedSessionExecutor

pub fn new() -> Self

创建新的隔离会话执行器

Trait Implementations

impl Default for IsolatedSessionExecutor

fn default() -> Self

Returns the “default value” for a type.

impl TaskExecutor for IsolatedSessionExecutor

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

获取执行器名称