Struct RayonCpuDomainExecutor 

pub struct RayonCpuDomainExecutor { /* private fields */ }

Adapter that executes CPU-domain jobs on one caller-owned Rayon pool.

The adapter retains the supplied pool and never creates, reconfigures, or shuts it down. CpuDomainExecutor remains the primary injection contract; this type is only a convenience for Rayon hosts.

Examples

use std::sync::Arc;
use tenferro_cpu::{CpuDomainExecutor, RayonCpuDomainExecutor};

let pool = Arc::new(rayon::ThreadPoolBuilder::new().num_threads(2).build()?);
let executor = RayonCpuDomainExecutor::new(Arc::clone(&pool));
assert_eq!(executor.capabilities().worker_count.get(), 2);
assert_eq!(Arc::strong_count(&pool), 2);

Implementations

impl RayonCpuDomainExecutor

pub fn new(pool: Arc<ThreadPool>) -> Self

Retain one caller-owned Rayon pool as a CPU-domain executor.

Examples

use std::sync::Arc;
use tenferro_cpu::{CpuDomainExecutor, RayonCpuDomainExecutor};

let pool = Arc::new(rayon::ThreadPoolBuilder::new().num_threads(2).build()?);
let executor = RayonCpuDomainExecutor::new(pool);
assert_eq!(executor.capabilities().worker_count.get(), 2);

Trait Implementations

impl CpuDomainExecutor for RayonCpuDomainExecutor

fn capabilities(&self) -> CpuDomainExecutorCapabilities

Return immutable construction-time executor capabilities.

fn submit(&self, jobs: &dyn ScopedCpuJobs) -> Result<(), CpuDomainExecutorError>

Submit all indexed jobs as one synchronous fork/join operation.

fn install( &self, job: &mut dyn ScopedCpuJob, ) -> Result<(), CpuDomainExecutorError>

Enter one synchronous provider-owned inner parallel region.

impl Debug for RayonCpuDomainExecutor

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

Formats the value using the given formatter.