aboutsummaryrefslogtreecommitdiffstats
path: root/components/util/workqueue.rs
diff options
context:
space:
mode:
authorMs2ger <ms2ger@gmail.com>2015-03-21 18:44:39 +0100
committerMs2ger <ms2ger@gmail.com>2015-03-21 18:44:39 +0100
commitba87666cdbf4addf9340aad0dd0cf9574b79091c (patch)
tree6a7b6b4d0a28f0302029f0c82ab3c63290287d6e /components/util/workqueue.rs
parent29a36adbe7d87fb38ba9bef3a718c6c823fb5977 (diff)
downloadservo-ba87666cdbf4addf9340aad0dd0cf9574b79091c.tar.gz
servo-ba87666cdbf4addf9340aad0dd0cf9574b79091c.zip
Update some code that's feature-gated under core.
Diffstat (limited to 'components/util/workqueue.rs')
-rw-r--r--components/util/workqueue.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/components/util/workqueue.rs b/components/util/workqueue.rs
index b1709cdf6e0..c368e56e930 100644
--- a/components/util/workqueue.rs
+++ b/components/util/workqueue.rs
@@ -231,7 +231,7 @@ impl<QueueData: Send, WorkData: Send> WorkQueue<QueueData, WorkData> {
// Set up data structures.
let (supervisor_chan, supervisor_port) = channel();
let (mut infos, mut threads) = (vec!(), vec!());
- for i in range(0, thread_count) {
+ for i in 0..thread_count {
let (worker_chan, worker_port) = channel();
let pool = BufferPool::new();
let (worker, thief) = pool.deque();
@@ -250,8 +250,8 @@ impl<QueueData: Send, WorkData: Send> WorkQueue<QueueData, WorkData> {
}
// Connect workers to one another.
- for i in range(0, thread_count) {
- for j in range(0, thread_count) {
+ for i in 0..thread_count {
+ for j in 0..thread_count {
if i != j {
threads[i].other_deques.push(infos[j].thief.clone())
}
@@ -312,7 +312,7 @@ impl<QueueData: Send, WorkData: Send> WorkQueue<QueueData, WorkData> {
}
// Get our deques back.
- for _ in range(0, self.workers.len()) {
+ for _ in 0..self.workers.len() {
match self.port.recv().unwrap() {
SupervisorMsg::ReturnDeque(index, deque) => self.workers[index].deque = Some(deque),
SupervisorMsg::Finished => panic!("unexpected finished message!"),