messaging_thread_pool 5.0.3

A library for aiding the creation of typed thread pool of objects that is communicated with via channels
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

mod send;

use std::thread::JoinHandle;

use crossbeam_channel::Sender;

use crate::{pool_item::PoolItem, sender_couplet::SenderCouplet};

/// A thread endpoint represents a thread within a thread pool
///
/// It consists of a channel to make requests on and a join handle
#[derive(Debug)]
pub(crate) struct ThreadEndpoint<P>
where
    P: PoolItem,
{
    sender: Sender<SenderCouplet<P>>,
    join_handle: JoinHandle<u64>,
}

impl<P> ThreadEndpoint<P>
where
    P: PoolItem,
{
    pub(crate) fn new(sender: Sender<SenderCouplet<P>>, join_handle: JoinHandle<u64>) -> Self {
        Self {
            sender,
            join_handle,
        }
    }

    pub(crate) fn join_handle(self) -> JoinHandle<u64> {
        self.join_handle
    }
}