Skip to main content

AsyncGroup

Struct AsyncGroup 

Source
pub struct AsyncGroup { /* private fields */ }
Expand description

The structure that allows for the concurrent execution of multiple functions using std::thread and waits for all of them to complete.

Functions are added using the add method and are then run concurrently in separate threads. The AsyncGroup ensures that all tasks finish before proceeding, and can collect any errors that occur.

Implementations§

Source§

impl AsyncGroup

Source

pub fn add<F>(&mut self, f: F)
where F: FnOnce() -> Result<()> + Send + 'static,

Adds a task (a closure) to the group to be executed concurrently.

This provided closure is executed in a new std::thread concurrently with other added tasks.

§Type Parameters
  • F: The type of the closure, which must be FnOnce() -> errs::Result<()> + Send + 'static.
§Parameters
  • f: The closure to be executed in a separate thread.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.