Struct ArcCallable 

pub struct ArcCallable<R, E> { /* private fields */ }

Thread-safe callable.

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

Type Parameters

• R - The success value returned by the computation.
• E - The error value returned when the computation fails.

Implementations

impl<R, E> ArcCallable<R, E>

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

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

Creates a new callable.

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

Examples found in repository

examples/tasks/task_demo.rs (lines 93-96)

fn demo_shared_callable() {
    println!("--- Shared callable ---");

    let mut call_count = 0;
    let shared = ArcCallable::new(move || {
        call_count += 1;
        Ok::<usize, String>(call_count)
    });

    let mut first = shared.clone();
    let mut second = shared.clone();
    println!("ArcCallable first clone: {:?}", first.call());
    println!("ArcCallable second clone: {:?}", second.call());
}

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

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

Creates a new named callable.

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<R, E> + Send + 'static,

Creates a new named callable 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<R, E>> + Send + 'static,

Creates an ArcCallable from a reusable supplier.

Parameters

• supplier - The supplier that produces the callable result.

Returns

A new ArcCallable<R, E>.

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

Gets the name of this callable.

Returns

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

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

Sets the name of this callable.

Parameters

• name - The name to set for this callable

pub fn clear_name(&mut self)

Clears the name of this callable.

Trait Implementations

impl<R, E> Callable<R, E> for ArcCallable<R, E>

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

Executes the thread-safe callable.

fn into_local_once(self) -> LocalBoxCallableOnce<R, E>

where Self: Sized + 'static,

Converts this shared callable into a local boxed one-time callable while preserving its name.

fn to_local_once(&self) -> LocalBoxCallableOnce<R, E>

where Self: Clone + Sized + 'static,

Converts this shared callable into a local boxed one-time callable without consuming self.

fn into_runnable(self) -> BoxRunnable<E>

where Self: Sized + 'static,

Converts this shared callable into a boxed runnable while preserving its name.

fn into_box(self) -> BoxCallable<R, E>

where Self: 'static,

Converts this callable into a boxed callable.

fn into_rc(self) -> RcCallable<R, E>

where Self: 'static,

Converts this callable into an Rc callable.

fn into_arc(self) -> ArcCallable<R, E>

Converts this callable into an Arc callable.

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

Converts this callable into a mutable closure.

fn into_once(self) -> BoxCallableOnce<R, E>

where Self: 'static,

Converts this callable into a one-time callable.

fn to_box(&self) -> BoxCallable<R, E>

where Self: 'static,

Converts this callable into a boxed callable without consuming self.

fn to_rc(&self) -> RcCallable<R, E>

where Self: 'static,

Converts this callable into an Rc callable without consuming self.

fn to_arc(&self) -> ArcCallable<R, E>

Converts this callable into an Arc callable without consuming self.

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

Converts this callable into a mutable closure without consuming self.

fn to_once(&self) -> BoxCallableOnce<R, E>

where Self: 'static,

Converts this callable into a one-time callable without consuming self.

impl<R, E> Clone for ArcCallable<R, E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R, E> Debug for ArcCallable<R, E>

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

Formats the value using the given formatter.

impl<R, E> Display for ArcCallable<R, E>

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

Formats the value using the given formatter.