Struct ArcRunnable 

pub struct ArcRunnable<E> { /* private fields */ }

Thread-safe runnable.

ArcRunnable<E> stores an Arc<Mutex<dyn FnMut() -> Result<(), E> + Send>> and can be called repeatedly across threads.

Type Parameters

• E - The error value returned when the action fails.

Author

Haixing Hu

Implementations

impl<E> ArcRunnable<E>

pub fn new<F>(function: F) -> Self

where F: FnMut() -> Result<(), E> + Send + 'static,

Creates a new runnable.

Wraps the provided closure in the appropriate smart pointer type for this runnable implementation.

pub fn new_with_name<F>(name: &str, function: F) -> Self

where F: FnMut() -> Result<(), E> + Send + 'static,

Creates a new named runnable.

Wraps the provided closure and assigns it a name, which is useful for debugging and logging purposes.

pub fn new_with_optional_name<F>(function: F, name: Option<String>) -> Self

where F: FnMut() -> Result<(), E> + Send + 'static,

Creates a new named runnable with an optional name.

Wraps the provided closure and assigns it an optional name.

pub fn from_supplier<S>(supplier: S) -> Self

where S: Supplier<Result<(), E>> + Send + 'static,

Creates a thread-safe runnable from a reusable supplier.

Parameters

• supplier - The supplier that produces the runnable result.

Returns

A new ArcRunnable<E>.

pub fn name(&self) -> Option<&str>

Gets the name of this runnable.

Returns

Returns Some(&str) if a name was set, None otherwise.

pub fn set_name(&mut self, name: &str)

Sets the name of this runnable.

Parameters

• name - The name to set for this runnable

pub fn clear_name(&mut self)

Clears the name of this runnable.

Trait Implementations

impl<E> Clone for ArcRunnable<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E> Runnable<E> for ArcRunnable<E>

fn run(&mut self) -> Result<(), E>

Executes the thread-safe runnable.

fn into_box(self) -> BoxRunnable<E>

where Self: 'static,

Converts this runnable into a boxed runnable.

fn into_rc(self) -> RcRunnable<E>

where Self: 'static,

Converts this runnable into a shared single-threaded runnable.

fn into_arc(self) -> ArcRunnable<E>

Converts this runnable into a shared thread-safe runnable.

fn into_fn(self) -> impl FnMut() -> Result<(), E>

Converts this runnable into a mutable closure.

fn to_box(&self) -> BoxRunnable<E>

where Self: 'static,

Converts this runnable into a boxed runnable without consuming self.

fn to_rc(&self) -> RcRunnable<E>

where Self: 'static,

Converts this runnable into a shared single-threaded runnable without consuming self.

fn to_arc(&self) -> ArcRunnable<E>

Converts this runnable into a shared thread-safe runnable without consuming self.

fn to_fn(&self) -> impl FnMut() -> Result<(), E>

Converts this runnable into a mutable closure without consuming self.

fn into_callable(self) -> BoxCallable<(), E>

where Self: Sized + 'static,

Converts this runnable into a callable returning unit.