Enum messaging_thread_pool::ThreadRequestResponse

pub enum ThreadRequestResponse<P>where
    P: PoolItem,{
    ThreadShutdown(RequestResponse<P, ThreadShutdownRequest>),
    ThreadAbort(RequestResponse<P, ThreadAbortRequest>),
    ThreadEcho(RequestResponse<P, ThreadEchoRequest>),
    AddPoolItem(RequestResponse<P, P::Init>),
    RemovePoolItem(RequestResponse<P, RemovePoolItemRequest>),
    MessagePoolItem(P::Api),
}

This enum defines all of the messages that can be used to communicate with the thread pool. Each element of the enum takes a RequestResponse struct which can contain either a request or a response

Variants

ThreadShutdown(RequestResponse<P, ThreadShutdownRequest>)

Causes the message loop of the thread to be exited and the thread is rejoined to the main thread Give contained pool items the opportunity to (optionally) shut down a child thread pool

ThreadAbort(RequestResponse<P, ThreadAbortRequest>)

As shutdown but leaves all of the state thread state intact (for use in testing)

ThreadEcho(RequestResponse<P, ThreadEchoRequest>)

For testing thread communications in test

AddPoolItem(RequestResponse<P, P::Init>)

Add a new pool item to the thread pool The pool item will be assigned a thread within the thread pool and it will be instantiated there It remain on that thread for its entire life The form of the message to create the pool item is defined by the pool item

RemovePoolItem(RequestResponse<P, RemovePoolItemRequest>)

Requests that an item be removed from the thread pool The request is routed to the thread that has ownership and the pool item is dropped

MessagePoolItem(P::Api)

Send a message from the pool items defined api to a given pool item The message is routed to the owning thread and any work is performed there

Trait Implementations

impl<P> Debug for ThreadRequestResponse<P>where P: PoolItem + Debug, P::Init: Debug, P::Api: Debug,

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

Formats the value using the given formatter.

impl<P> From<AddResponse> for ThreadRequestResponse<P>where P: PoolItem,

fn from(response: AddResponse) -> Self

Converts to this type from the input type.

impl From<MeanRequest> for ThreadRequestResponse<Randoms>

fn from(request: MeanRequest) -> Self

Converts to this type from the input type.

impl From<MeanResponse> for ThreadRequestResponse<Randoms>

fn from(response: MeanResponse) -> Self

Converts to this type from the input type.

impl From<PanicRequest> for ThreadRequestResponse<Randoms>

fn from(request: PanicRequest) -> Self

Converts to this type from the input type.

impl From<PanicResponse> for ThreadRequestResponse<Randoms>

fn from(response: PanicResponse) -> Self

Converts to this type from the input type.

impl From<RandomsAddRequest> for ThreadRequestResponse<Randoms>

fn from(add_request: RandomsAddRequest) -> Self

Converts to this type from the input type.

impl From<RandomsApi> for ThreadRequestResponse<Randoms>

fn from(request_response: RandomsApi) -> Self

Converts to this type from the input type.

impl<P> From<RandomsBatchAddRequest<P>> for ThreadRequestResponse<RandomsBatch<P>>where P: SenderAndReceiver<Randoms> + Send + Sync + Debug,

fn from(request: RandomsBatchAddRequest<P>) -> Self

Converts to this type from the input type.

impl<P> From<RandomsBatchApi<P>> for ThreadRequestResponse<RandomsBatch<P>>where P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

fn from(request_response: RandomsBatchApi<P>) -> Self

Converts to this type from the input type.

impl<P> From<RemovePoolItemRequest> for ThreadRequestResponse<P>where P: PoolItem,

fn from(request: RemovePoolItemRequest) -> Self

Converts to this type from the input type.

impl<T> From<RemovePoolItemResponse> for ThreadRequestResponse<T>where T: PoolItem,

fn from(request: RemovePoolItemResponse) -> Self

Converts to this type from the input type.

impl<P> From<SumOfSumsRequest> for ThreadRequestResponse<RandomsBatch<P>>where P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

fn from(request: SumOfSumsRequest) -> Self

Converts to this type from the input type.

impl<P> From<SumOfSumsResponse> for ThreadRequestResponse<RandomsBatch<P>>where P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

fn from(response: SumOfSumsResponse) -> Self

Converts to this type from the input type.

impl From<SumRequest> for ThreadRequestResponse<Randoms>

fn from(request: SumRequest) -> Self

Converts to this type from the input type.

impl From<SumResponse> for ThreadRequestResponse<Randoms>

fn from(response: SumResponse) -> Self

Converts to this type from the input type.

impl<P> From<ThreadAbortRequest> for ThreadRequestResponse<P>where P: PoolItem,

fn from(request: ThreadAbortRequest) -> Self

Converts to this type from the input type.

impl<T> From<ThreadAbortResponse> for ThreadRequestResponse<T>where T: PoolItem,

fn from(request: ThreadAbortResponse) -> Self

Converts to this type from the input type.

impl<P> From<ThreadEchoRequest> for ThreadRequestResponse<P>where P: PoolItem,

fn from(request: ThreadEchoRequest) -> Self

Converts to this type from the input type.

impl<T> From<ThreadEchoResponse> for ThreadRequestResponse<T>where T: PoolItem,

fn from(request: ThreadEchoResponse) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<P>> for AddResponsewhere P: PoolItem,

fn from(response: ThreadRequestResponse<P>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<P>> for RemovePoolItemResponsewhere P: PoolItem,

fn from(response: ThreadRequestResponse<P>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<P>> for ThreadAbortResponsewhere P: PoolItem,

fn from(response: ThreadRequestResponse<P>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<P>> for ThreadEchoResponsewhere P: PoolItem,

fn from(response: ThreadRequestResponse<P>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<P>> for ThreadShutdownResponsewhere P: PoolItem,

fn from(response: ThreadRequestResponse<P>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for MeanRequest

fn from(request: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for MeanResponse

fn from(response: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for PanicRequest

fn from(request: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for PanicResponse

fn from(response: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for RandomsAddRequest

fn from(response: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for RandomsApi

fn from(response: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for SumRequest

fn from(request: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl From<ThreadRequestResponse<Randoms>> for SumResponse

fn from(response: ThreadRequestResponse<Randoms>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<RandomsBatch<P>>> for RandomsBatchAddRequest<P>where P: SenderAndReceiver<Randoms> + Send + Sync + Debug,

fn from(response: ThreadRequestResponse<RandomsBatch<P>>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<RandomsBatch<P>>> for RandomsBatchApi<P>where P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

fn from(response: ThreadRequestResponse<RandomsBatch<P>>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<RandomsBatch<P>>> for SumOfSumsRequestwhere P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

fn from(request: ThreadRequestResponse<RandomsBatch<P>>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadRequestResponse<RandomsBatch<P>>> for SumOfSumsResponsewhere P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

fn from(response: ThreadRequestResponse<RandomsBatch<P>>) -> Self

Converts to this type from the input type.

impl<P> From<ThreadShutdownRequest> for ThreadRequestResponse<P>where P: PoolItem,

fn from(request: ThreadShutdownRequest) -> Self

Converts to this type from the input type.

impl<T> From<ThreadShutdownResponse> for ThreadRequestResponse<T>where T: PoolItem,

fn from(request: ThreadShutdownResponse) -> Self

Converts to this type from the input type.

impl<P> PartialEq<ThreadRequestResponse<P>> for ThreadRequestResponse<P>where P: PoolItem + PartialEq, P::Init: PartialEq, P::Api: PartialEq,

fn eq(&self, other: &ThreadRequestResponse<P>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<P> RequestWithResponse<P> for ThreadRequestResponse<P>where P: PoolItem,

A ThreadRequestResponse is always a RequestWithResponse

type Response = ThreadRequestResponse<P>

impl<P> StructuralPartialEq for ThreadRequestResponse<P>where P: PoolItem,