Lines Matching refs:spawn
11 use tokio_test::task::spawn;
25 let mut t1 = spawn(rwlock.read()); in read_shared()
27 let mut t2 = spawn(rwlock.read()); in read_shared()
35 let mut t1 = spawn(rwlock.read()); in write_shared_pending()
38 let mut t2 = spawn(rwlock.write()); in write_shared_pending()
46 let mut t1 = spawn(rwlock.write()); in read_exclusive_pending()
49 let mut t2 = spawn(rwlock.read()); in read_exclusive_pending()
60 let mut t = spawn(rwlock.read()); in exhaust_reading()
67 let mut t1 = spawn(rwlock.read()); in exhaust_reading()
79 let mut t1 = spawn(rwlock.write()); in write_exclusive_pending()
82 let mut t2 = spawn(rwlock.write()); in write_exclusive_pending()
90 let mut t1 = spawn(rwlock.read()); in write_shared_drop()
93 let mut t2 = spawn(rwlock.write()); in write_shared_drop()
105 let mut t1 = spawn(rwlock.read()); in write_read_shared_pending()
108 let mut t2 = spawn(rwlock.read()); in write_read_shared_pending()
111 let mut t3 = spawn(rwlock.write()); in write_read_shared_pending()
114 let mut t4 = spawn(rwlock.read()); in write_read_shared_pending()
123 let mut t1 = spawn(rwlock.read()); in write_read_shared_drop_pending()
126 let mut t2 = spawn(rwlock.write()); in write_read_shared_drop_pending()
129 let mut t3 = spawn(rwlock.read()); in write_read_shared_drop_pending()
179 tokio::spawn(async move { in multithreaded()
193 tokio::spawn(async move { in multithreaded()
207 tokio::spawn(async move { in multithreaded()
221 tokio::spawn(async move { in multithreaded()