Struct bp3d_threads::ThreadPool

pub struct ThreadPool<'env, Manager: ThreadManager<'env>, T: Send + 'static> { /* fields omitted */ }

Core thread pool.

Implementations

impl<'env, Manager: ThreadManager<'env>, T: Send> ThreadPool<'env, Manager, T>

pub fn new(n_threads: usize) -> Self

Creates a new thread pool

Arguments

• n_threads: maximum number of threads allowed to run at the same time.

returns: ThreadPool<T, Manager>

Examples

use bp3d_threads::UnscopedThreadManager;
use bp3d_threads::ThreadPool;
let _: ThreadPool<UnscopedThreadManager, ()> = ThreadPool::new(4);

pub fn dispatch<F: FnOnce(usize) -> T + Send + 'env>(
    &mut self,
    manager: &Manager,
    f: F
) -> bool

Schedule a new task to run.

Returns true if the task was successfully scheduled, false otherwise.

The task execution order is not guaranteed, however the task index is guaranteed to be the order of the call to dispatch.

If a task panics it will leave a dead thread in the corresponding slot until .join() is called.

Arguments

• manager: the thread manager to spawn a new thread if needed.
• f: the task function to execute.

returns: bool

Examples

use bp3d_threads::UnscopedThreadManager;
use bp3d_threads::ThreadPool;
let manager = UnscopedThreadManager::new();
let mut pool: ThreadPool<UnscopedThreadManager, ()> = ThreadPool::new(4);
pool.dispatch(&manager, |_| ());

pub fn is_idle(&self) -> bool

Returns true if this thread pool is idle.

An idle thread pool does neither have running threads nor waiting tasks but may still have waiting results to poll.

pub fn poll(&mut self) -> Option<T>

Poll a result from this thread pool if any, returns None if no result is available.

pub fn join(&mut self) -> Result<()>

Waits for all tasks to finish execution and stops all threads.

Use this to periodically clean-up the thread pool, if you know that some tasks may panic.

Errors

Returns an error if a thread did panic.