Struct mz_timely_util::builder_async::ButtonHandle
source · pub struct ButtonHandle {
buttons_remaining: usize,
local_pressed: Rc<Cell<bool>>,
puller: Box<dyn Pull<Bincode<bool>>>,
}
Expand description
A button that can be used to coordinate an action after all workers have pressed it.
Fields§
The number of buttons still unpressed among workers.
local_pressed: Rc<Cell<bool>>
A flag indicating whether this worker has pressed its button.
puller: Box<dyn Pull<Bincode<bool>>>
Implementations§
source§impl ButtonHandle
impl ButtonHandle
sourcepub fn local_pressed(&self) -> bool
pub fn local_pressed(&self) -> bool
Returns whether this worker has pressed its button.
sourcepub fn all_pressed(&mut self) -> bool
pub fn all_pressed(&mut self) -> bool
Returns whether all workers have pressed their buttons.
Auto Trait Implementations§
impl Freeze for ButtonHandle
impl !RefUnwindSafe for ButtonHandle
impl !Send for ButtonHandle
impl !Sync for ButtonHandle
impl Unpin for ButtonHandle
impl !UnwindSafe for ButtonHandle
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<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.