about summary refs log tree commit diff
path: root/src/libstd/sync
diff options
context:
space:
mode:
authorNiko Matsakis <niko@alum.mit.edu>2015-02-17 09:47:49 -0500
committerNiko Matsakis <niko@alum.mit.edu>2015-02-18 09:09:12 -0500
commit2b5720a15fd7e8ae3883dcaee556b000e962b052 (patch)
tree967aa12a6089aca54098adf56e97abff223b8798 /src/libstd/sync
parent700c518f2afd4b759fb54b867aee62660188d870 (diff)
downloadrust-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.rs6
-rw-r--r--src/libstd/sync/mpsc/mod.rs20
-rw-r--r--src/libstd/sync/mpsc/mpsc_queue.rs6
-rw-r--r--src/libstd/sync/mpsc/select.rs16
-rw-r--r--src/libstd/sync/mpsc/spsc_queue.rs2
-rw-r--r--src/libstd/sync/mutex.rs4
-rw-r--r--src/libstd/sync/once.rs6
-rw-r--r--src/libstd/sync/rwlock.rs4
-rw-r--r--src/libstd/sync/task_pool.rs14
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();
             });
         }