diff options
Diffstat (limited to 'src/libextra/task_pool.rs')
| -rw-r--r-- | src/libextra/task_pool.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/libextra/task_pool.rs b/src/libextra/task_pool.rs index d6eed24ef8d..bda6935643f 100644 --- a/src/libextra/task_pool.rs +++ b/src/libextra/task_pool.rs @@ -57,7 +57,7 @@ impl<T> TaskPool<T> { let (port, chan) = comm::stream::<Msg<T>>(); let init_fn = init_fn_factory(); - let task_body: proc() = || { + let task_body: proc() = proc() { let local_data = init_fn(i); loop { match port.recv() { @@ -98,11 +98,11 @@ impl<T> TaskPool<T> { #[test] fn test_task_pool() { let f: || -> proc(uint) -> uint = || { - let g: proc(uint) -> uint = |i| i; + let g: proc(uint) -> uint = proc(i) i; g }; let mut pool = TaskPool::new(4, Some(SingleThreaded), f); 8.times(|| { - pool.execute(|i| println!("Hello from thread {}!", *i)); + pool.execute(proc(i) println!("Hello from thread {}!", *i)); }) } |
