Struct bp3d_threads::ScopedThreadManager

pub struct ScopedThreadManager<'env, 'scope>(_);

Represents a ScopedThreadManager (to use with crossbeam::scope).

Implementations

impl<'env, 'scope> ScopedThreadManager<'env, 'scope>

pub fn new(scope: &'env Scope<'scope>) -> Self

Creates new ScopedThreadManager.

Arguments

• scope: the Scope to use.

returns: ScopedThreadManager

Examples

use bp3d_threads::ThreadPool;
use bp3d_threads::ScopedThreadManager;
crossbeam::scope(|scope| {
    let manager = ScopedThreadManager::new(scope);
    let mut pool: ThreadPool<ScopedThreadManager, i32> = ThreadPool::new(4);
    assert!(pool.is_idle());
    pool.dispatch(&manager, |_| 12);
    assert!(!pool.is_idle());
    pool.join().unwrap();
    assert!(pool.is_idle());
}).unwrap();

Trait Implementations

impl<'env, 'scope: 'env> ThreadManager<'scope> for ScopedThreadManager<'env, 'scope>

type Handle = ScopedJoinHandle<'env, ()>

The type of thread handle (must have a join() function).

fn spawn_thread<F: FnOnce() + Send + 'scope>(&self, func: F) -> Self::Handle

Spawns a thread using this manager.