Struct AsyncProcessor

pub struct AsyncProcessor { /* private fields */ }

A processor that can execute async tasks with a limit on the number of tasks that can be executed concurrently.

Implementations

impl AsyncProcessor

pub fn new( metric_name: &str, number_of_threads: usize, number_of_pending_tasks: usize, ) -> Result<Self>

Create a new AsyncProcessor with the given number of threads and the number of pending tasks.

pub fn reserve(&self) -> Result<AsyncReservation, OutOfCapacity>

Reserve a slot for a task to be executed.

pub fn spawn_reserved<F>( &self, reservation: AsyncReservation, future: F, ) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send,

Spawn a task with a reservation.

pub fn try_spawn<F>( &self, future: F, ) -> Result<JoinHandle<F::Output>, OutOfCapacity>

where F: Future + Send + 'static, F::Output: Send,

Tries to spawn a task. If the task cannot be spawned, returns an error.

Trait Implementations

impl Drop for AsyncProcessor

fn drop(&mut self)

Executes the destructor for this type.