Crate tokio_rayon

Tokio’s spawn_blocking and block_in_place run blocking code on a potentially large number of Tokio-controlled threads. This is suitable for blocking I/O, but CPU-heavy operations are often better served by a fixed-size thread pool. The Rayon crate provides exactly this, so… Why not combine them? :)

let nft = tokio_rayon::spawn(|| {
  do_some_crypto_stuff()
}).await;

assert_eq!(nft, ExpensiveNft);

Re-exports

pub use rayon;

Structs

AsyncRayonHandle

Async handle for a blocking task running in a Rayon thread pool.

Traits

AsyncThreadPool

Extension trait that integrates Rayon’s ThreadPool with Tokio.

Functions

spawn

Asynchronous wrapper around Rayon’s spawn.

spawn_fifo

Asynchronous wrapper around Rayon’s spawn_fifo.