Struct TaskScheduler 

pub struct TaskScheduler { /* private fields */ }

Port of struct TaskScheduler (CLI/src/Analyze.cpp:323-392).

A thread pool scheduler for parallel task execution, mirroring the C++ design: std::mutex + std::condition_variable guarding a std::queue<std::function<void()>>, with one std::thread per worker. Native-only; not portable to wasm32-unknown-unknown.

Implementations

impl TaskScheduler

pub fn task_scheduler_task_scheduler(thread_count: u32) -> Self

TaskScheduler(unsigned threadCount) (CLI/src/Analyze.cpp:325-337): spawns threadCount worker threads, each running workerFunction().

impl TaskScheduler

pub fn get_thread_count() -> u32

static unsigned getThreadCount() (CLI/src/Analyze.cpp:375-378): return std::max(std::thread::hardware_concurrency(), 1u);

Trait Implementations

impl Debug for TaskScheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for TaskScheduler

fn drop(&mut self)

~TaskScheduler() (CLI/src/Analyze.cpp:339-346): pushes one empty task per worker, then joins them.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.