A generic task spawner compatible with any async runtime.
This crate provides a Spawner type that abstracts task spawning across
different async runtimes without generic infection.
- Concrete type: No generics needed in your code
- Simple: Use built-in constructors or provide a closure
- Flexible: Works with any async runtime
use anyspawn::Spawner;
let spawner = Spawner::new_tokio();
let result = spawner.spawn(async { 1 + 1 }).await;
assert_eq!(result, 2);use anyspawn::Spawner;
let spawner = Spawner::new_custom("threadpool", |fut| {
std::thread::spawn(move || futures::executor::block_on(fut));
});
// Returns a JoinHandle that can be awaited or dropped
let handle = spawner.spawn(async { 42 });Spawner implements ThreadAware and supports
per-core isolation via Spawner::new_thread_aware, enabling
contention-free, NUMA-friendly task dispatch. See the
thread-aware section on Spawner for
details and examples.
tokio(default): Enables theSpawner::new_tokioandSpawner::new_tokio_with_handleconstructorscustom: EnablesSpawner::new_customandCustomSpawnerBuilder
This crate was developed as part of The Oxidizer Project. Browse this crate's source code.
