pub enum JoinStrategy {
All,
Any,
Quorum(usize),
Percentage(f64),
PartialResults(usize),
PartialTimeout,
}Expand description
Strategy for joining parallel tasks
Variants§
All
All tasks must complete successfully
Any
Any single task completion triggers join
Quorum(usize)
Specific number of tasks must complete
Percentage(f64)
Percentage of tasks must complete (0.0 to 1.0)
PartialResults(usize)
Accept partial results - continues after minimum tasks complete successfully, cancels remaining tasks, and returns both successes and errors Parameter is the minimum number of tasks that must complete successfully
PartialTimeout
Accept whatever completes before timeout - cancels tasks that haven’t completed when timeout expires, and proceeds with completed tasks (successes and failures) Requires timeout to be set in JoinConfig
Implementations§
Source§impl JoinStrategy
impl JoinStrategy
Sourcepub fn is_satisfied(&self, completed: usize, total: usize) -> bool
pub fn is_satisfied(&self, completed: usize, total: usize) -> bool
Check if the join condition is met based on completed/total tasks
Trait Implementations§
Source§impl Clone for JoinStrategy
impl Clone for JoinStrategy
Source§fn clone(&self) -> JoinStrategy
fn clone(&self) -> JoinStrategy
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for JoinStrategy
impl Debug for JoinStrategy
Source§impl PartialEq for JoinStrategy
impl PartialEq for JoinStrategy
impl StructuralPartialEq for JoinStrategy
Auto Trait Implementations§
impl Freeze for JoinStrategy
impl RefUnwindSafe for JoinStrategy
impl Send for JoinStrategy
impl Sync for JoinStrategy
impl Unpin for JoinStrategy
impl UnwindSafe for JoinStrategy
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