Struct timely::synchronization::barrier::Barrier
source · pub struct Barrier<A: Allocate> { /* private fields */ }
Expand description
A re-usable barrier synchronization mechanism.
Implementations§
source§impl<A: Allocate> Barrier<A>
impl<A: Allocate> Barrier<A>
sourcepub fn wait(&mut self)
pub fn wait(&mut self)
Blocks until all other workers have reached this barrier.
This method does not block dataflow execution, which continues to execute while we await the arrival of the other workers.
Auto Trait Implementations§
impl<A> Freeze for Barrier<A>
impl<A> !RefUnwindSafe for Barrier<A>
impl<A> !Send for Barrier<A>
impl<A> !Sync for Barrier<A>
impl<A> Unpin for Barrier<A>
impl<A> !UnwindSafe for Barrier<A>
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
source§impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.