Struct TPool 

pub struct TPool { /* private fields */ }

Thread pool handle — equivalent to TPool* in the C API.

TPool_create → TPool::new TPool_free → Drop for TPool (joins workers automatically) TPool_submitJob → TPool::submit_job TPool_jobsCompleted → TPool::jobs_completed

Implementations

impl TPool

pub fn new(nb_threads: usize, queue_size: usize) -> Option<Self>

TPool_create(nbThreads, queueSize) — returns None on failure.

nbThreads must be ≥ 1, queueSize must be ≥ 1. The C code allocates one extra queue slot to distinguish full vs. empty; here crossbeam_channel::bounded(queue_size + nb_threads) plays the same role as the semaphore initialised to queueSize + nbWorkers in the Windows implementation.

pub fn submit_job(&self, job: Box<dyn FnOnce() + Send + 'static>)

TPool_submitJob(ctx, job_function, arg) — may block if queue is full.

In C the caller passes a raw void (*fn)(void*) + void* arg. In Rust the equivalent is a Box<dyn FnOnce() + Send> closure that has already captured its argument, eliminating the void* anti-pattern.

pub fn jobs_completed(&self)

TPool_jobsCompleted(ctx) — blocks until all submitted jobs have finished.

Does NOT shut down the pool; it can accept further jobs afterwards, identical to the C semantics.

Trait Implementations

impl Drop for TPool

fn drop(&mut self)

TPool_free — waits for all running jobs to finish then tears down the rayon pool. rayon’s ThreadPool already joins workers on drop, so we only need to ensure no jobs are still in-flight first.