jtp 0.1.1

A simple implementation of thread pool, similar to the ThreadPoolExecutor in java.
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

use std::{panic::UnwindSafe, sync::Arc};

pub type TaskFn = Box<dyn FnOnce() + Send + UnwindSafe + 'static>;

pub(crate) struct TaskListeners {
    pub(crate) before_execute: Box<dyn Fn(usize) + Send + Sync>,
    pub(crate) after_execute: Box<dyn Fn(usize) + Send + Sync>,
}

pub struct Task {
    id: usize,
    task_fn: TaskFn,
    listeners: Arc<TaskListeners>,
}

impl Task {
    pub(crate) fn create(id: usize, task_fn: TaskFn, listeners: Arc<TaskListeners>) -> Self {
        Self {
            id,
            task_fn,
            listeners,
        }
    }

    pub(crate) fn run(self) {
        let listeners = self.listeners;
        (listeners.before_execute)(self.id);
        (self.task_fn)();
        (listeners.after_execute)(self.id);
    }
}