Struct BlockingSpawner 

pub struct BlockingSpawner { /* private fields */ }

Executes blocking closures on the current thread (via tokio::task::block_in_place) with bounded concurrency from a semaphore.

On a CurrentThread runtime, block_in_place panics, so the spawner falls back to calling the closure directly.

Implementations

impl BlockingSpawner

pub fn new(max_blocking: usize) -> Self

Create a new spawner with the given concurrency limit.

Detects the current tokio runtime flavor to decide whether block_in_place is safe.

Trait Implementations

impl Clone for BlockingSpawner

fn clone(&self) -> BlockingSpawner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BlockingSpawner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.