From d645f87c6d04019bc15bfedd7a204942be17ee04 Mon Sep 17 00:00:00 2001 From: Brian Anderson Date: Fri, 11 Nov 2011 15:50:57 -0800 Subject: [PATCH] Rehabilitate run-pass/task-comm.rs --- src/test/run-pass/task-comm.rs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/test/run-pass/task-comm.rs b/src/test/run-pass/task-comm.rs index 5fa212064de0..ad4bb2ee1ce6 100644 --- a/src/test/run-pass/task-comm.rs +++ b/src/test/run-pass/task-comm.rs @@ -1,4 +1,3 @@ -// xfail-test use std; import std::task; @@ -19,7 +18,8 @@ fn main() { test06(); } -fn test00_start(ch: chan, message: int, count: int) { +fn test00_start(&&args: (chan, int, int)) { + let (ch, message, count) = args; log "Starting test00_start"; let i: int = 0; while i < count { @@ -43,8 +43,8 @@ fn test00() { let tasks = []; while i < number_of_tasks { i = i + 1; - let thunk = bind test00_start(ch, i, number_of_messages); - tasks += [task::spawn_joinable(thunk)]; + tasks += [task::spawn_joinable( + (ch, i, number_of_messages), test00_start)]; } let sum: int = 0; for t in tasks { @@ -90,7 +90,7 @@ fn test03() { log v.length(); } -fn test04_start() { +fn test04_start(&&_args: ()) { log "Started task"; let i: int = 1024 * 1024; while i > 0 { i = i - 1; } @@ -100,7 +100,7 @@ fn test04_start() { fn test04() { log "Spawning lots of tasks."; let i: int = 4; - while i > 0 { i = i - 1; let f = test04_start; task::spawn(f); } + while i > 0 { i = i - 1; task::spawn((), test04_start); } log "Finishing up."; } @@ -115,7 +115,7 @@ fn test05_start(ch: chan) { fn test05() { let po = comm::port(); let ch = chan(po); - task::spawn(bind test05_start(ch)); + task::spawn(ch, test05_start); let value: int; value = recv(po); value = recv(po); @@ -123,7 +123,7 @@ fn test05() { log value; } -fn test06_start(task_number: int) { +fn test06_start(&&task_number: int) { log "Started task."; let i: int = 0; while i < 1000000 { i = i + 1; } @@ -139,7 +139,7 @@ fn test06() { let tasks = []; while i < number_of_tasks { i = i + 1; - tasks += [task::spawn_joinable(bind test06_start(i))]; + tasks += [task::spawn_joinable(copy i, test06_start)]; }