Struct email::thread_pool::ThreadPool

pub struct ThreadPool<C: ThreadPoolContext> {
    tx: UnboundedSender<ThreadPoolTask<C>>,
    rx: Arc<Mutex<UnboundedReceiver<ThreadPoolTask<C>>>>,
    threads: Vec<JoinHandle<Result<()>>>,
}

The thread pool.

Fields

tx: UnboundedSender<ThreadPoolTask<C>>

Channel used by the pool.

This channel is used to send tasks to threads.

rx: Arc<Mutex<UnboundedReceiver<ThreadPoolTask<C>>>>

Channel used by threads.

Only one thread can receive a task at a time. When a thread receives a task, it releases the lock and a new thread can receive the next task.

threads: Vec<JoinHandle<Result<()>>>

The list of threads spawned by the pool.

Implementations

impl<C> ThreadPool<C>

where C: ThreadPoolContext + 'static,

pub async fn exec<F, T>( &self, task: impl FnOnce(Arc<C>) -> F + Send + Sync + 'static ) -> T

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Execute the given task and awaits for its resolution.

The task is sent to the pool channel and will be executed by the first available thread. This function awaits for its resolution.

pub async fn close(self)

Abort pool threads and close the channel.