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

mod message_loop;
pub mod new;
pub mod shutdown_child_pool;

use std::collections::HashMap;

use crossbeam_channel::Receiver;

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

/// This structure represents a thread within the thread pool
pub struct PoolThread<P>
where
    P: PoolItem,
{
    /// A unique id assigned to the pool thread
    thread_id: u64,
    /// Stores the channel on which requests will be received
    pool_thread_receiver: Receiver<SenderCouplet<P>>,
    /// This is a hash map that will hold the ownership of all pool items created in this
    /// pool thread keyed by their ids
    pool_item_map: HashMap<u64, P>,
}