2 unstable releases
| 0.2.0 | Mar 8, 2022 |
|---|---|
| 0.1.0 | Sep 6, 2018 |
#118 in #scope
83,729 downloads per month
Used in 9 crates
15KB
287 lines
A scoped tokio Runtime that can be used to create Scopes which can spawn futures which
can access stack data. That is, the futures spawned by the Scope do not require the 'static
lifetime bound. This can be done safely by ensuring that the Scope doesn't exit until all
spawned futures have finished executing. Be aware, that when a Scope exits it will block
until every future spawned by the Scope completes. Therefore, one should take caution when
created scopes within an asynchronous context, such as from within another spawned future.
Example
#[tokio::main]
async fn main() {
let mut v = String::from("Hello");
tokio_scoped::scope(|scope| {
// Use the scope to spawn the future.
scope.spawn(async {
v.push('!');
});
});
// The scope won't exit until all spawned futures are complete.
assert_eq!(v.as_str(), "Hello!");
}
See also crossbeam::scope
tokio-scoped
tokio-scoped provides a scope function inspired by crossbeam
but for the tokio Runtime. A scope allows one to spawn futures which do not have a 'static lifetime
by ensuring each future spawned in the scope completes before the scope exits.
Example
#[tokio::main]
async fn main() {
let mut v = String::from("Hello");
tokio_scoped::scope(|scope| {
// Use the scope to spawn the future.
scope.spawn(async {
v.push('!');
});
});
// The scope won't exit until all spawned futures are complete.
assert_eq!(v.as_str(), "Hello!");
}
Dependencies
~1.8–2.6MB
~37K SLoC