Struct TaskServer

pub struct TaskServer {
    ctrl: Control,
    cancel_tx: Sender<bool>,
}

タスクサーバ本体。

Fields

ctrl: Control

各タスクに clone して渡すオリジナルの Control。

cancel_tx: Sender<bool>

システムシャットダウン時の中断リクエストの送信側。 https://tokio.rs/tokio/topics/shutdown “Telling things to shut down” + “Waiting for things to finish shutting down”

Implementations

impl TaskServer

pub fn new(sysmods: SystemModules) -> Self

タスクサーバを生成して初期化する。

pub fn spawn_oneshot_task<F, T>(&self, name: &str, f: F)

where F: Fn(Control) -> T + Send + Sync + 'static, T: Future<Output = Result<()>> + Send,

spawn_oneshot_task を内蔵の Self::ctrl を使って呼び出す。

pub fn run<F1, F2>(self, usr1_handler: F1, usr2_handler: F2) -> RunResult

where F1: Fn() -> Option<RunResult>, F2: Fn() -> Option<RunResult>,

実行を開始し、完了するまでブロックする。

self の所有権を consume するため、一度しか実行できない。

F: シグナルハンドラ。実行を終了するならば Some, 続行するならば None を返す。