Struct AsyncTaskSystem 

pub struct AsyncTaskSystem { /* private fields */ }

非同期Task システム

Implementations

impl AsyncTaskSystem

pub fn new(runtime: Handle) -> Self

新規作成

pub fn spawn<T: AsyncTask>(&self, task: T) -> TaskId

Worker/Manager から Task を発行

pub fn spawn_boxed(&self, task: Box<dyn AsyncTask>) -> TaskId

Box を発行（ファクトリ経由で生成された Task 用）

pub fn collect_results(&self) -> Vec<AsyncTaskResult>

完了したTaskの結果を収集（ノンブロッキング）

pub fn register_factory<F: AsyncTaskFactory + 'static>( &mut self, name: &str, factory: F, )

Task ファクトリを登録（ユーザー拡張ポイント）

pub fn create_task( &self, name: &str, params: TaskParams, ) -> Option<Box<dyn AsyncTask>>

ファクトリからTaskを生成