about summary refs log tree commit diff
path: root/src/libextra/task_pool.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/libextra/task_pool.rs')
-rw-r--r--src/libextra/task_pool.rs17
1 files changed, 8 insertions, 9 deletions
diff --git a/src/libextra/task_pool.rs b/src/libextra/task_pool.rs
index b88bbff2a66..49d5dd93869 100644
--- a/src/libextra/task_pool.rs
+++ b/src/libextra/task_pool.rs
@@ -13,15 +13,14 @@
 /// A task pool abstraction. Useful for achieving predictable CPU
 /// parallelism.
 
-use core::prelude::*;
 
-use core::comm::Chan;
-use core::comm;
-use core::task::SchedMode;
-use core::task;
-use core::vec;
+use std::comm::Chan;
+use std::comm;
+use std::task::SchedMode;
+use std::task;
+use std::vec;
 
-#[cfg(test)] use core::task::SingleThreaded;
+#[cfg(test)] use std::task::SingleThreaded;
 
 enum Msg<T> {
     Execute(~fn(&T)),
@@ -35,8 +34,8 @@ pub struct TaskPool<T> {
 
 #[unsafe_destructor]
 impl<T> Drop for TaskPool<T> {
-    fn finalize(&self) {
-        for self.channels.each |channel| {
+    fn drop(&self) {
+        for self.channels.iter().advance |channel| {
             channel.send(Quit);
         }
     }