Struct BarrierWaitResult 

pub struct BarrierWaitResult(/* private fields */);

A BarrierWaitResult is returned by Barrier::wait() when all systems in the Barrier have rendezvoused.

Examples

use dtypes::redis::sync::Barrier;

let client = redis::Client::open("redis://localhost:6379").unwrap();
let mut  barrier = Barrier::new(1, "barrier_doc_test", client);
let barrier_wait_result = barrier.wait();

Implementations

impl BarrierWaitResult

pub fn is_leader(&self) -> bool

Returns true if this thread is the “leader thread” for the call to Barrier::wait().

Only one thread will have true returned from their result, all other threads will have false returned.

Examples

use dtypes::redis::sync::Barrier;

let client = redis::Client::open("redis://localhost:6379").unwrap();
let mut  barrier = Barrier::new(1, "barrier_doc_test", client);
let barrier_wait_result = barrier.wait();
println!("{:?}", barrier_wait_result.is_leader());