Struct sync_threadpool::ThreadPool

pub struct ThreadPool { /* fields omitted */ }

This is the thread pool.

Methods

impl ThreadPool

pub fn new(n: usize) -> Self

Create a new ThreadPool.

Example

use sync_threadpool::ThreadPool;

let pool = ThreadPool::new(4);

pub fn wait_for_all(&self)

Wait for all workers to be idle.

pub fn execute<F>(&mut self, job: F) where     F: FnOnce() + Send + 'static,

Submit a job to the threadpool. This method blocks until a worker becomes idle.

pub fn try_execute<F>(&mut self, job: F) -> Result<(), ()> where     F: FnOnce() + Send + 'static,

Submit a job to the threadpool. This method is nonblocking, if no worker is idle, it will Return an error.

Example

use std::sync::{Arc, Barrier};
use sync_threadpool::ThreadPool;

let mut pool = ThreadPool::new(2);
let barrier = Arc::new(Barrier::new(3));
let b1 = barrier.clone();
let b2 = barrier.clone();

pool.try_execute(move || {
    b1.wait();
}).unwrap();
pool.try_execute(move || {
    b2.wait();
}).unwrap();

pool.try_execute(move || {}).unwrap_err();

barrier.wait();
pool.wait_for_all();

pool.try_execute(move || {}).unwrap();

Trait Implementations

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.