Struct SolverManager 

pub struct SolverManager<S: Solvable> { /* private fields */ }

Manages async solve jobs with channel-based solution streaming.

Uses fixed-size slot array for job tracking. Solutions stream through tokio channels - the solver sends owned solutions, users receive them without cloning.

Type Parameters

• S - Solution type that implements Solvable

Thread Safety

SolverManager is thread-safe. Jobs can be started, queried, and terminated from any thread.

Implementations

impl<S: Solvable> SolverManager<S>

where S::Score: Score,

pub const fn new() -> Self

Creates a new SolverManager with empty slots.

pub fn solve( &'static self, solution: S, ) -> (usize, UnboundedReceiver<(S, S::Score)>)

Starts solving and returns a receiver for streaming solutions.

The solver runs asynchronously via rayon. Solutions stream through the returned receiver as they’re found. Each solution is owned - no cloning occurs.

Arguments

• solution - The starting solution (ownership transferred)

Returns

A tuple of (job_id, receiver). The receiver yields (solution, score) pairs as new best solutions are found.

Panics

Panics if no free slots are available.

pub fn get_status(&self, job_id: usize) -> SolverStatus

Gets the solver status for a job.

pub fn terminate_early(&self, job_id: usize) -> bool

Requests early termination of a job.

Returns true if the job was found and is currently solving.

pub fn free_slot(&self, job_id: usize)

Frees a job slot after solving completes.

Call this after the receiver is drained to allow reuse of the slot.

pub fn active_job_count(&self) -> usize

Returns the number of active (solving) jobs.

Trait Implementations

impl<S: Solvable> Default for SolverManager<S>

fn default() -> Self

Returns the “default value” for a type.