@@ -162,10 +162,10 @@ impl ThreadTests {
162
162
let mut thread_commands = Vec :: new ( ) ;
163
163
164
164
for _ in 0 ..count {
165
- let sem = Arc :: new ( Semaphore :: new ( 0 , u32:: MAX ) . unwrap ( ) ) ;
165
+ let sem = Arc :: new ( Semaphore :: new ( 0 , u32:: MAX ) ) ;
166
166
result. sems . push ( sem. clone ( ) ) ;
167
167
168
- let sem = Arc :: new ( Semaphore :: new ( 0 , u32:: MAX ) . unwrap ( ) ) ;
168
+ let sem = Arc :: new ( Semaphore :: new ( 0 , u32:: MAX ) ) ;
169
169
result. back_sems . push ( sem) ;
170
170
171
171
let chans = ChanPair :: new_bounded ( 1 ) ;
@@ -902,7 +902,7 @@ impl SimpleMain {
902
902
fn new ( count : usize , workq : Arc < WorkQueue > ) -> Self {
903
903
Self {
904
904
locked : SpinMutex :: new ( Locked :: new ( count) ) ,
905
- done : Semaphore :: new ( 0 , 1 ) . unwrap ( ) ,
905
+ done : Semaphore :: new ( 0 , 1 ) ,
906
906
workq,
907
907
}
908
908
}
@@ -953,7 +953,7 @@ fn spin_bench() {
953
953
#[ no_mangle]
954
954
fn sem_bench ( ) {
955
955
let iters = 10_000 ;
956
- let sem = Semaphore :: new ( iters as u32 , iters as u32 ) . unwrap ( ) ;
956
+ let sem = Semaphore :: new ( iters as u32 , iters as u32 ) ;
957
957
let timer = BenchTimer :: new ( "Semaphore take" , iters) ;
958
958
for _ in 0 ..iters {
959
959
sem. take ( Forever ) . unwrap ( ) ;
0 commit comments