Skip to content

pchickey/task-group

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

20 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Please use tokio::task::JoinSet instead

This crate pre-dated tokio::task::JoinSet. JoinSet is probably a better abstraction and implementation than this crate: please consider using it instead.

task-group

A small crate for managing groups of tokio tasks.

let (task_group, task_manager): (TaskGroup<Error>, TaskManager<_>) = TaskGroup::new();

task_group.clone().spawn("a task", async move {
    task_group.spawn("b task", async move {
        /* all kinds of things */
        Ok(())
    }).await.expect("spawned b");
    Ok(())
}).await.expect("spawned a");

task_manager.await.expect("everyone successful");

A TaskGroup is used to spawn a collection of tasks. The collection has two properties:

  • if any task returns an error or panicks, all tasks are terminated.
  • if the TaskManager returned by TaskGroup::new is dropped, all tasks are terminated.

A TaskManager is used to manage a collection of tasks. There are two things you can do with it:

  • TaskManager impls Future, so you can poll or await on it. It will be Ready when all tasks return Ok(()) and the associated TaskGroup is dropped (so no more tasks can be created), or when any task panicks or returns an Err(E).
  • When a TaskManager is dropped, all tasks it contains are canceled (terminated). So, if you use a combinator like tokio::time::timeout(duration, task_manager).await, all tasks will be terminated if the timeout occurs.

See examples/ and the tests in src/lib.rs for more examples.

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages