Lines Matching refs:RwLock
10 use tokio::sync::{Barrier, RwLock};
16 let rwlock = RwLock::new(42); in into_inner()
23 let rwlock = RwLock::new(100); in read_shared()
34 let rwlock = RwLock::new(100); in write_shared_pending()
45 let rwlock = RwLock::new(100); in read_exclusive_pending()
57 let rwlock = RwLock::with_max_readers(100, 1024); in exhaust_reading()
78 let rwlock = RwLock::new(100); in write_exclusive_pending()
89 let rwlock = RwLock::new(100); in write_shared_drop()
104 let rwlock = RwLock::new(100); in write_read_shared_pending()
122 let rwlock = RwLock::new(100); in write_read_shared_drop_pending()
140 let rwlock = RwLock::new(100); in read_uncontested()
149 let rwlock = RwLock::new(100); in write_uncontested()
158 let rwlock = RwLock::<Vec<u32>>::new(vec![]); in write_order()
172 let rwlock = Arc::new(RwLock::<u32>::new(0)); in multithreaded()
241 let lock = RwLock::new(0); in try_write()
250 let lock: RwLock<usize> = RwLock::new(15); in try_read_try_write()