pub struct AutoParallelizer { /* private fields */ }Expand description
Automatic parallelizer.
Implementations§
Source§impl AutoParallelizer
impl AutoParallelizer
Sourcepub fn with_strategy(self, strategy: ParallelizationStrategy) -> Self
pub fn with_strategy(self, strategy: ParallelizationStrategy) -> Self
Set parallelization strategy.
Sourcepub fn with_cost_model(self, model: CostModel) -> Self
pub fn with_cost_model(self, model: CostModel) -> Self
Set cost model.
Sourcepub fn with_max_workers(self, workers: usize) -> Self
pub fn with_max_workers(self, workers: usize) -> Self
Set maximum number of workers.
Sourcepub fn update_profile(&mut self, op_type: String, time_us: f64)
pub fn update_profile(&mut self, op_type: String, time_us: f64)
Update profile data with observed execution times.
Sourcepub fn analyze(
&self,
nodes: &[NodeInfo],
) -> Result<ParallelizationAnalysis, AutoParallelError>
pub fn analyze( &self, nodes: &[NodeInfo], ) -> Result<ParallelizationAnalysis, AutoParallelError>
Analyze graph for parallelization opportunities.
Sourcepub fn generate_plan(
&self,
nodes: &[NodeInfo],
) -> Result<ParallelExecutionPlan, AutoParallelError>
pub fn generate_plan( &self, nodes: &[NodeInfo], ) -> Result<ParallelExecutionPlan, AutoParallelError>
Generate parallel execution plan.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for AutoParallelizer
impl RefUnwindSafe for AutoParallelizer
impl Send for AutoParallelizer
impl Sync for AutoParallelizer
impl Unpin for AutoParallelizer
impl UnwindSafe for AutoParallelizer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more