rmanoka/async-scoped

A scope for async_std and tokio to spawn non-static futures

Rust

160

57 commits

updated May 28, 2024

See the code

README

Async-scoped

Enables controlled spawning of non-'static futures when using the async-std or tokio executors.

Motivation

Present executors (such as async-std, tokio, etc.) all support spawning 'static futures onto a thread-pool. However, they do not support spawning futures with lifetime smaller than 'static.

While the future combinators such as for_each_concurrent offer concurrency, they are bundled as a single Task structure by the executor, and hence are not driven in parallel. This can be seen when benchmarking a reasonable number (> ~1K) of I/O futures, or a few CPU heavy futures.

Usage

The API is meant to be a minimal wrapper around efficient executors. Users may use "use-async-std", or the "use-tokio" features, to obtain a specific global executor implementation. These features provide TokioScope and AsyncScope that support spawning, and blocking. However, none of those features are necessary - you may freely implement your own executor. See docs.rs for detailed documentation.

License

Licensed under either of Apache License, Version 2.0 or MIT license at your option.

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in this crate by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

async
rust

Contributors

rmanoka

42 commits

akoshelev

8 commits

ftelnov

3 commits

rmanoka/async-scoped

A scope for async_std and tokio to spawn non-static futures

Rust

160

57 commits

updated May 28, 2024

See the code

README

Async-scoped

Enables controlled spawning of non-'static futures when using the async-std or tokio executors.

Motivation

Present executors (such as async-std, tokio, etc.) all support spawning 'static futures onto a thread-pool. However, they do not support spawning futures with lifetime smaller than 'static.

While the future combinators such as for_each_concurrent offer concurrency, they are bundled as a single Task structure by the executor, and hence are not driven in parallel. This can be seen when benchmarking a reasonable number (> ~1K) of I/O futures, or a few CPU heavy futures.

Usage

The API is meant to be a minimal wrapper around efficient executors. Users may use "use-async-std", or the "use-tokio" features, to obtain a specific global executor implementation. These features provide TokioScope and AsyncScope that support spawning, and blocking. However, none of those features are necessary - you may freely implement your own executor. See docs.rs for detailed documentation.

License

Licensed under either of Apache License, Version 2.0 or MIT license at your option.

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in this crate by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

async
rust

Contributors

rmanoka

42 commits

akoshelev

8 commits

ftelnov

3 commits

Languages

Rust

100.0%