diff options
| author | Connor Tsui <connor.tsui20@gmail.com> | 2025-07-22 13:52:10 +0200 |
|---|---|---|
| committer | Connor Tsui <connor.tsui20@gmail.com> | 2025-08-23 09:20:46 -0400 |
| commit | a8163bd6f4f2bc3ba8fb56df9d48622070ba68ab (patch) | |
| tree | e0f6d717809166387d66321d938ae9dee066fa3b /library/std/src | |
| parent | b2380d2bcc429b1ac8d800bc2fdce90de81d1454 (diff) | |
| download | rust-a8163bd6f4f2bc3ba8fb56df9d48622070ba68ab.tar.gz rust-a8163bd6f4f2bc3ba8fb56df9d48622070ba68ab.zip | |
change `Barrier` implementation to use `nonpoison::Condvar`
Signed-off-by: Connor Tsui <connor.tsui20@gmail.com>
Diffstat (limited to 'library/std/src')
| -rw-r--r-- | library/std/src/sync/barrier.rs | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/library/std/src/sync/barrier.rs b/library/std/src/sync/barrier.rs index 067ff66d9af..712ce03f90b 100644 --- a/library/std/src/sync/barrier.rs +++ b/library/std/src/sync/barrier.rs @@ -1,6 +1,5 @@ use crate::fmt; -// FIXME(nonpoison_mutex,nonpoison_condvar): switch to nonpoison versions once they are available -use crate::sync::{Condvar, Mutex}; +use crate::sync::nonpoison::{Condvar, Mutex}; /// A barrier enables multiple threads to synchronize the beginning /// of some computation. @@ -118,12 +117,11 @@ impl Barrier { /// ``` #[stable(feature = "rust1", since = "1.0.0")] pub fn wait(&self) -> BarrierWaitResult { - let mut lock = self.lock.lock().unwrap(); + let mut lock = self.lock.lock(); let local_gen = lock.generation_id; lock.count += 1; if lock.count < self.num_threads { - let _guard = - self.cvar.wait_while(lock, |state| local_gen == state.generation_id).unwrap(); + let _guard = self.cvar.wait_while(lock, |state| local_gen == state.generation_id); BarrierWaitResult(false) } else { lock.count = 0; |
