53 lines
1.5 KiB
Rust
53 lines
1.5 KiB
Rust
//! A thin wrapper around [`stdx::thread::Pool`] which threads a sender through spawned jobs.
|
|
//! It is used in [`crate::global_state::GlobalState`] throughout the main loop.
|
|
|
|
use crossbeam_channel::Sender;
|
|
use stdx::thread::{Pool, ThreadIntent};
|
|
|
|
use crate::main_loop::QueuedTask;
|
|
|
|
pub(crate) struct TaskPool<T> {
|
|
sender: Sender<T>,
|
|
pool: Pool,
|
|
}
|
|
|
|
impl<T> TaskPool<T> {
|
|
pub(crate) fn new_with_threads(sender: Sender<T>, threads: usize) -> TaskPool<T> {
|
|
TaskPool { sender, pool: Pool::new(threads) }
|
|
}
|
|
|
|
pub(crate) fn spawn<F>(&mut self, intent: ThreadIntent, task: F)
|
|
where
|
|
F: FnOnce() -> T + Send + 'static,
|
|
T: Send + 'static,
|
|
{
|
|
self.pool.spawn(intent, {
|
|
let sender = self.sender.clone();
|
|
move || sender.send(task()).unwrap()
|
|
})
|
|
}
|
|
|
|
pub(crate) fn spawn_with_sender<F>(&mut self, intent: ThreadIntent, task: F)
|
|
where
|
|
F: FnOnce(Sender<T>) + Send + 'static,
|
|
T: Send + 'static,
|
|
{
|
|
self.pool.spawn(intent, {
|
|
let sender = self.sender.clone();
|
|
move || task(sender)
|
|
})
|
|
}
|
|
|
|
pub(crate) fn len(&self) -> usize {
|
|
self.pool.len()
|
|
}
|
|
}
|
|
|
|
/// `TaskQueue`, like its name suggests, queues tasks.
|
|
///
|
|
/// This should only be used used if a task must run after [`GlobalState::process_changes`]
|
|
/// has been called.
|
|
pub(crate) struct TaskQueue {
|
|
pub(crate) sender: crossbeam_channel::Sender<QueuedTask>,
|
|
pub(crate) receiver: crossbeam_channel::Receiver<QueuedTask>,
|
|
}
|