Struct market::thread::Thread

pub struct Thread<S, E> { /* fields omitted */ }

A wrapper around the std::thread functionality.

Consumes the status of running the given closure. Thus, consumption replaces the functionality of std::thread::JoinHandle::join().

Implementations

impl<S: Send + 'static, E: TryFrom<ConsumeFailure<E>> + Send + 'static> Thread<S, E>

pub fn new<P: Send + 'static, F: FnMut(&mut P) -> Result<S, E> + RefUnwindSafe + Send + 'static>(
    name: String,
    kind: Kind,
    mut parameters: P,
    mut call: F
) -> Self

Creates a new Thread and spawns call.

pub fn cancel(&self)

Requests that self be canceled.

Trait Implementations

impl<S, E: TryFrom<ConsumeFailure<E>>> Consumer for Thread<S, E>

type Good = S

The item being consumed.

type Failure = ConsumeFailure<E>

Describes a failure to successfully complete consumption.

fn consume(&self) -> Result<Self::Good, Self::Failure>

Retrieves the next good from the market without blocking.

fn goods(&self) -> Goods<'_, Self> where
    Self: Sized, 

Returns a Goods of self.

fn demand(&self) -> Result<Self::Good, <Self::Failure as Failure>::Fault>

Retrieves the next good from the market, blocking until one is available.

impl<S: Debug, E: Debug> Debug for Thread<S, E>

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

Formats the value using the given formatter.