36 lines
820 B
Rust
36 lines
820 B
Rust
|
//! A thin wrapper around `ThreadPool` to make sure that we join all things
|
||
|
|
//! properly.
|
||
|
|
use crossbeam_channel::Sender;
|
||
|
|
|
||
|
|
pub(crate) struct TaskPool<T> {
|
||
|
|
sender: Sender<T>,
|
||
|
|
inner: threadpool::ThreadPool,
|
||
|
|
}
|
||
|
|
|
||
|
|
impl<T> TaskPool<T> {
|
||
|
|
pub(crate) fn new(sender: Sender<T>) -> TaskPool<T> {
|
||
|
|
TaskPool { sender, inner: threadpool::ThreadPool::default() }
|
||
|
|
}
|
||
|
|
|
||
|
|
pub(crate) fn spawn<F>(&mut self, task: F)
|
||
|
|
where
|
||
|
|
F: FnOnce() -> T + Send + 'static,
|
||
|
|
T: Send + 'static,
|
||
|
|
{
|
||
|
|
self.inner.execute({
|
||
|
|
let sender = self.sender.clone();
|
||
|
|
move || sender.send(task()).unwrap()
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
pub(crate) fn len(&self) -> usize {
|
||
|
|
self.inner.queued_count()
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
impl<T> Drop for TaskPool<T> {
|
||
|
|
fn drop(&mut self) {
|
||
|
|
self.inner.join()
|
||
|
|
}
|
||
|
|
}
|