diff options
Diffstat (limited to 'src/libextra/task_pool.rs')
| -rw-r--r-- | src/libextra/task_pool.rs | 17 |
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); } } |
