diff options
| author | Niko Matsakis <niko@alum.mit.edu> | 2015-02-17 09:47:49 -0500 |
|---|---|---|
| committer | Niko Matsakis <niko@alum.mit.edu> | 2015-02-18 09:09:12 -0500 |
| commit | 2b5720a15fd7e8ae3883dcaee556b000e962b052 (patch) | |
| tree | 967aa12a6089aca54098adf56e97abff223b8798 /src/libstd/sync | |
| parent | 700c518f2afd4b759fb54b867aee62660188d870 (diff) | |
| download | rust-2b5720a15fd7e8ae3883dcaee556b000e962b052.tar.gz rust-2b5720a15fd7e8ae3883dcaee556b000e962b052.zip | |
Remove `i`, `is`, `u`, or `us` suffixes that are not necessary.
Diffstat (limited to 'src/libstd/sync')
| -rw-r--r-- | src/libstd/sync/barrier.rs | 6 | ||||
| -rw-r--r-- | src/libstd/sync/mpsc/mod.rs | 20 | ||||
| -rw-r--r-- | src/libstd/sync/mpsc/mpsc_queue.rs | 6 | ||||
| -rw-r--r-- | src/libstd/sync/mpsc/select.rs | 16 | ||||
| -rw-r--r-- | src/libstd/sync/mpsc/spsc_queue.rs | 2 | ||||
| -rw-r--r-- | src/libstd/sync/mutex.rs | 4 | ||||
| -rw-r--r-- | src/libstd/sync/once.rs | 6 | ||||
| -rw-r--r-- | src/libstd/sync/rwlock.rs | 4 | ||||
| -rw-r--r-- | src/libstd/sync/task_pool.rs | 14 |
9 files changed, 39 insertions, 39 deletions
diff --git a/src/libstd/sync/barrier.rs b/src/libstd/sync/barrier.rs index fc781eb4bec..b036177af15 100644 --- a/src/libstd/sync/barrier.rs +++ b/src/libstd/sync/barrier.rs @@ -18,7 +18,7 @@ use sync::{Mutex, Condvar}; /// use std::thread; /// /// let barrier = Arc::new(Barrier::new(10)); -/// for _ in 0u..10 { +/// for _ in 0..10 { /// let c = barrier.clone(); /// // The same messages will be printed together. /// // You will NOT see any interleaving. @@ -120,7 +120,7 @@ mod tests { let barrier = Arc::new(Barrier::new(N)); let (tx, rx) = channel(); - for _ in 0u..N - 1 { + for _ in 0..N - 1 { let c = barrier.clone(); let tx = tx.clone(); thread::spawn(move|| { @@ -138,7 +138,7 @@ mod tests { let mut leader_found = barrier.wait().is_leader(); // Now, the barrier is cleared and we should get data. - for _ in 0u..N - 1 { + for _ in 0..N - 1 { if rx.recv().unwrap() { assert!(!leader_found); leader_found = true; diff --git a/src/libstd/sync/mpsc/mod.rs b/src/libstd/sync/mpsc/mod.rs index 410d3c0ecd5..21993e51669 100644 --- a/src/libstd/sync/mpsc/mod.rs +++ b/src/libstd/sync/mpsc/mod.rs @@ -1147,9 +1147,9 @@ mod test { fn stress() { let (tx, rx) = channel::<int>(); let t = thread::spawn(move|| { - for _ in 0u..10000 { tx.send(1).unwrap(); } + for _ in 0..10000 { tx.send(1).unwrap(); } }); - for _ in 0u..10000 { + for _ in 0..10000 { assert_eq!(rx.recv().unwrap(), 1); } t.join().ok().unwrap(); @@ -1209,7 +1209,7 @@ mod test { assert_eq!(rx.recv().unwrap(), 1); } }); - for _ in 0u..40 { + for _ in 0..40 { tx.send(1).unwrap(); } t.join().ok().unwrap(); @@ -1530,7 +1530,7 @@ mod test { tx2.send(()).unwrap(); }); // make sure the other task has gone to sleep - for _ in 0u..5000 { thread::yield_now(); } + for _ in 0..5000 { thread::yield_now(); } // upgrade to a shared chan and send a message let t = tx.clone(); @@ -1654,9 +1654,9 @@ mod sync_tests { fn stress() { let (tx, rx) = sync_channel::<int>(0); thread::spawn(move|| { - for _ in 0u..10000 { tx.send(1).unwrap(); } + for _ in 0..10000 { tx.send(1).unwrap(); } }); - for _ in 0u..10000 { + for _ in 0..10000 { assert_eq!(rx.recv().unwrap(), 1); } } @@ -1893,8 +1893,8 @@ mod sync_tests { fn recv_a_lot() { // Regression test that we don't run out of stack in scheduler context let (tx, rx) = sync_channel(10000); - for _ in 0u..10000 { tx.send(()).unwrap(); } - for _ in 0u..10000 { rx.recv().unwrap(); } + for _ in 0..10000 { tx.send(()).unwrap(); } + for _ in 0..10000 { rx.recv().unwrap(); } } #[test] @@ -1994,7 +1994,7 @@ mod sync_tests { tx2.send(()).unwrap(); }); // make sure the other task has gone to sleep - for _ in 0u..5000 { thread::yield_now(); } + for _ in 0..5000 { thread::yield_now(); } // upgrade to a shared chan and send a message let t = tx.clone(); @@ -2082,7 +2082,7 @@ mod sync_tests { rx2.recv().unwrap(); } - for _ in 0u..100 { + for _ in 0..100 { repro() } } diff --git a/src/libstd/sync/mpsc/mpsc_queue.rs b/src/libstd/sync/mpsc/mpsc_queue.rs index 0a4ff8769ab..a2accb128c3 100644 --- a/src/libstd/sync/mpsc/mpsc_queue.rs +++ b/src/libstd/sync/mpsc/mpsc_queue.rs @@ -171,8 +171,8 @@ mod tests { #[test] fn test() { - let nthreads = 8u; - let nmsgs = 1000u; + let nthreads = 8; + let nmsgs = 1000; let q = Queue::new(); match q.pop() { Empty => {} @@ -192,7 +192,7 @@ mod tests { }); } - let mut i = 0u; + let mut i = 0; while i < nthreads * nmsgs { match q.pop() { Empty | Inconsistent => {}, diff --git a/src/libstd/sync/mpsc/select.rs b/src/libstd/sync/mpsc/select.rs index 4756ef612f9..8fcedd2ab57 100644 --- a/src/libstd/sync/mpsc/select.rs +++ b/src/libstd/sync/mpsc/select.rs @@ -428,10 +428,10 @@ mod test { let (tx3, rx3) = channel::<int>(); let _t = thread::spawn(move|| { - for _ in 0u..20 { thread::yield_now(); } + for _ in 0..20 { thread::yield_now(); } tx1.send(1).unwrap(); rx3.recv().unwrap(); - for _ in 0u..20 { thread::yield_now(); } + for _ in 0..20 { thread::yield_now(); } }); select! { @@ -452,7 +452,7 @@ mod test { let (tx3, rx3) = channel::<()>(); let _t = thread::spawn(move|| { - for _ in 0u..20 { thread::yield_now(); } + for _ in 0..20 { thread::yield_now(); } tx1.send(1).unwrap(); tx2.send(2).unwrap(); rx3.recv().unwrap(); @@ -557,7 +557,7 @@ mod test { tx3.send(()).unwrap(); }); - for _ in 0u..1000 { thread::yield_now(); } + for _ in 0..1000 { thread::yield_now(); } drop(tx1.clone()); tx2.send(()).unwrap(); rx3.recv().unwrap(); @@ -670,7 +670,7 @@ mod test { tx2.send(()).unwrap(); }); - for _ in 0u..100 { thread::yield_now() } + for _ in 0..100 { thread::yield_now() } tx1.send(()).unwrap(); rx2.recv().unwrap(); } @@ -690,7 +690,7 @@ mod test { tx2.send(()).unwrap(); }); - for _ in 0u..100 { thread::yield_now() } + for _ in 0..100 { thread::yield_now() } tx1.send(()).unwrap(); rx2.recv().unwrap(); } @@ -709,7 +709,7 @@ mod test { tx2.send(()).unwrap(); }); - for _ in 0u..100 { thread::yield_now() } + for _ in 0..100 { thread::yield_now() } tx1.send(()).unwrap(); rx2.recv().unwrap(); } @@ -727,7 +727,7 @@ mod test { fn sync2() { let (tx, rx) = sync_channel::<int>(0); let _t = thread::spawn(move|| { - for _ in 0u..100 { thread::yield_now() } + for _ in 0..100 { thread::yield_now() } tx.send(1).unwrap(); }); select! { diff --git a/src/libstd/sync/mpsc/spsc_queue.rs b/src/libstd/sync/mpsc/spsc_queue.rs index b8f835bde51..e1a89706509 100644 --- a/src/libstd/sync/mpsc/spsc_queue.rs +++ b/src/libstd/sync/mpsc/spsc_queue.rs @@ -325,7 +325,7 @@ mod test { let (tx, rx) = channel(); let q2 = q.clone(); let _t = thread::spawn(move|| { - for _ in 0u..100000 { + for _ in 0..100000 { loop { match q2.pop() { Some(1) => break, diff --git a/src/libstd/sync/mutex.rs b/src/libstd/sync/mutex.rs index 65cae90857e..e77c4d2e5eb 100644 --- a/src/libstd/sync/mutex.rs +++ b/src/libstd/sync/mutex.rs @@ -60,7 +60,7 @@ use sys_common::mutex as sys; /// let data = Arc::new(Mutex::new(0)); /// /// let (tx, rx) = channel(); -/// for _ in 0u..10 { +/// for _ in 0..10 { /// let (data, tx) = (data.clone(), tx.clone()); /// thread::spawn(move || { /// // The shared static can only be accessed once the lock is held. @@ -87,7 +87,7 @@ use sys_common::mutex as sys; /// use std::sync::{Arc, Mutex}; /// use std::thread; /// -/// let lock = Arc::new(Mutex::new(0u)); +/// let lock = Arc::new(Mutex::new(0_u32)); /// let lock2 = lock.clone(); /// /// let _ = thread::spawn(move || -> () { diff --git a/src/libstd/sync/once.rs b/src/libstd/sync/once.rs index 1e87c0d612b..97f985e21e8 100644 --- a/src/libstd/sync/once.rs +++ b/src/libstd/sync/once.rs @@ -147,10 +147,10 @@ mod test { static mut run: bool = false; let (tx, rx) = channel(); - for _ in 0u..10 { + for _ in 0..10 { let tx = tx.clone(); thread::spawn(move|| { - for _ in 0u..4 { thread::yield_now() } + for _ in 0..4 { thread::yield_now() } unsafe { O.call_once(|| { assert!(!run); @@ -170,7 +170,7 @@ mod test { assert!(run); } - for _ in 0u..10 { + for _ in 0..10 { rx.recv().unwrap(); } } diff --git a/src/libstd/sync/rwlock.rs b/src/libstd/sync/rwlock.rs index b8d157d341e..cd833b17867 100644 --- a/src/libstd/sync/rwlock.rs +++ b/src/libstd/sync/rwlock.rs @@ -503,7 +503,7 @@ mod tests { thread::spawn(move|| { let mut lock = arc2.write().unwrap(); - for _ in 0u..10 { + for _ in 0..10 { let tmp = *lock; *lock = -1; thread::yield_now(); @@ -514,7 +514,7 @@ mod tests { // Readers try to catch the writer in the act let mut children = Vec::new(); - for _ in 0u..5 { + for _ in 0..5 { let arc3 = arc.clone(); children.push(thread::spawn(move|| { let lock = arc3.read().unwrap(); diff --git a/src/libstd/sync/task_pool.rs b/src/libstd/sync/task_pool.rs index f4274dd91cc..a45048be24c 100644 --- a/src/libstd/sync/task_pool.rs +++ b/src/libstd/sync/task_pool.rs @@ -63,17 +63,17 @@ impl<'a> Drop for Sentinel<'a> { /// use std::iter::AdditiveIterator; /// use std::sync::mpsc::channel; /// -/// let pool = TaskPool::new(4u); +/// let pool = TaskPool::new(4); /// /// let (tx, rx) = channel(); -/// for _ in 0..8u { +/// for _ in 0..8 { /// let tx = tx.clone(); /// pool.execute(move|| { -/// tx.send(1u).unwrap(); +/// tx.send(1_u32).unwrap(); /// }); /// } /// -/// assert_eq!(rx.iter().take(8u).sum(), 8u); +/// assert_eq!(rx.iter().take(8).sum(), 8); /// ``` pub struct TaskPool { // How the threadpool communicates with subthreads. @@ -142,7 +142,7 @@ mod test { use super::*; use sync::mpsc::channel; - const TEST_TASKS: uint = 4u; + const TEST_TASKS: uint = 4; #[test] fn test_works() { @@ -154,7 +154,7 @@ mod test { for _ in 0..TEST_TASKS { let tx = tx.clone(); pool.execute(move|| { - tx.send(1u).unwrap(); + tx.send(1).unwrap(); }); } @@ -183,7 +183,7 @@ mod test { for _ in 0..TEST_TASKS { let tx = tx.clone(); pool.execute(move|| { - tx.send(1u).unwrap(); + tx.send(1).unwrap(); }); } |
