Module task

Available on crate feature async only.

Tokio task utilities.

Named task spawning

The spawn and spawn_blocking methods are wrappers around tokio::task::spawn and tokio::task::spawn_blocking that attach a name the spawned task.

If Clippy sent you here, replace:

tokio::task::spawn(my_future)
tokio::task::spawn_blocking(my_blocking_closure)

with:

mz_ore::task::spawn(|| format!("taskname:{}", info), my_future)
mz_ore::task::spawn_blocking(|| format!("name:{}", info), my_blocking_closure)

If you are using methods of the same names on a Runtime or Handle, import RuntimeExt and replace spawn with RuntimeExt::spawn_named and spawn_blocking with RuntimeExt::spawn_blocking_named, adding naming closures like above.

Structs

AbortOnDropHandle

Wraps a JoinHandle to abort the underlying task when dropped.

JoinHandle

Wraps a tokio JoinHandle and provides 4 exclusive (i.e. they take self ownership) operations:

Traits

JoinHandleExt

Extension methods for JoinHandle and AbortOnDropHandle.

JoinSetExt

Extension methods for tokio::task::JoinSet.

RuntimeExt

Extension methods for Runtime and Handle.

Functions

spawn

Spawns a new asynchronous task with a name.

spawn_blocking

Runs the provided closure with a name on a thread where blocking is acceptable.

unpack_join_result 🔒