pub struct Barrier { /* fields omitted */ }
A barrier enables multiple threads to synchronize the beginning of some computation.
use std::sync::{Arc, Barrier};
use std::thread;
let mut handles = Vec::with_capacity(10);
let barrier = Arc::new(Barrier::new(10));
for _ in 0..10 {
let c = barrier.clone();
// The same messages will be printed together.
// You will NOT see any interleaving.
handles.push(thread::spawn(move|| {
println!("before wait");
c.wait();
println!("after wait");
}));
}
// Wait for other threads to finish.
for handle in handles {
handle.join().unwrap();
} impl Barrier
[src]
fn new(n: usize) -> BarrierCreates a new barrier that can block a given number of threads.
A barrier will block n-1 threads which call wait and then wake up all threads at once when the nth thread calls wait.
fn wait(&self) -> BarrierWaitResultBlocks the current thread until all threads have rendezvoused here.
Barriers are re-usable after all threads have rendezvoused once, and can be used continuously.
A single (arbitrary) thread will receive a BarrierWaitResult that returns true from is_leader when returning from this function, and all other threads will receive a result that will return false from is_leader
impl Debug for Barrier
fn fmt(&self, f: &mut Formatter) -> ResultFormats the value using the given formatter.
© 2010 The Rust Project Developers
Licensed under the Apache License, Version 2.0 or the MIT license, at your option.
https://doc.rust-lang.org/std/sync/struct.Barrier.html