diff options
author | Ms2ger <ms2ger@gmail.com> | 2015-03-21 18:44:39 +0100 |
---|---|---|
committer | Ms2ger <ms2ger@gmail.com> | 2015-03-21 18:44:39 +0100 |
commit | ba87666cdbf4addf9340aad0dd0cf9574b79091c (patch) | |
tree | 6a7b6b4d0a28f0302029f0c82ab3c63290287d6e /components/util/workqueue.rs | |
parent | 29a36adbe7d87fb38ba9bef3a718c6c823fb5977 (diff) | |
download | servo-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.rs | 8 |
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!"), |