diff --git a/src/test/run-pass/task-comm-10.rs b/src/test/run-pass/task-comm-10.rs index 0482a1ff96d..a96b3062d9f 100644 --- a/src/test/run-pass/task-comm-10.rs +++ b/src/test/run-pass/task-comm-10.rs @@ -1,6 +1,10 @@ // xfail-stage0 // xfail-stage1 // xfail-stage2 + +use std; +import std::task; + fn start(chan[chan[str]] c) { let port[str] p = port(); c <| chan(p); @@ -10,9 +14,9 @@ fn start(chan[chan[str]] c) { fn main() { let port[chan[str]] p = port(); - auto child = spawn "start" start(chan(p)); + auto child = spawn start(chan(p)); auto c; p |> c; c <| "A"; c <| "B"; - yield; + task::yield(); } diff --git a/src/test/run-pass/task-comm-11.rs b/src/test/run-pass/task-comm-11.rs index 49c6382e5b3..723966082c1 100644 --- a/src/test/run-pass/task-comm-11.rs +++ b/src/test/run-pass/task-comm-11.rs @@ -1,6 +1,7 @@ // xfail-stage0 // xfail-stage1 // xfail-stage2 + fn start(chan[chan[str]] c) { let port[str] p = port(); c <| chan(p); @@ -8,6 +9,6 @@ fn start(chan[chan[str]] c) { fn main() { let port[chan[str]] p = port(); - auto child = spawn "child" start(chan(p)); + auto child = spawn start(chan(p)); auto c; p |> c; } diff --git a/src/test/run-pass/task-comm-12.rs b/src/test/run-pass/task-comm-12.rs index a1677a3d2ce..4c8fc4c2ebf 100644 --- a/src/test/run-pass/task-comm-12.rs +++ b/src/test/run-pass/task-comm-12.rs @@ -1,8 +1,7 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + use std; -import std::_task; +import std::task; fn main() -> () { test00(); @@ -14,13 +13,13 @@ fn start(int task_number) { fn test00() { let int i = 0; - let task t = spawn thread "child" start(i); + let task t = spawn start(i); // Sleep long enough for the task to finish. - _task::sleep(10000u); + task::sleep(10000u); // Try joining tasks that have already finished. - join t; + task::join(t); log "Joined task."; } \ No newline at end of file diff --git a/src/test/run-pass/task-comm-13-thread.rs b/src/test/run-pass/task-comm-13-thread.rs deleted file mode 100644 index 72f3c9568fe..00000000000 --- a/src/test/run-pass/task-comm-13-thread.rs +++ /dev/null @@ -1,21 +0,0 @@ -// xfail-stage0 -// xfail-stage1 -// xfail-stage2 -use std; -import std::_task; - -fn start(chan[int] c, int start, int number_of_messages) { - let int i = 0; - while (i < number_of_messages) { - c <| start + i; - i += 1; - } -} - -fn main() -> () { - log "Check that we don't deadlock."; - let port[int] p = port(); - let task a = spawn thread "start" start(chan(p), 0, 10); - join a; - log "Joined task"; -} \ No newline at end of file diff --git a/src/test/run-pass/task-comm-13.rs b/src/test/run-pass/task-comm-13.rs index c6de853332e..50b667e8a2f 100644 --- a/src/test/run-pass/task-comm-13.rs +++ b/src/test/run-pass/task-comm-13.rs @@ -1,8 +1,7 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + use std; -import std::_task; +import std::task; fn start(chan[int] c, int start, int number_of_messages) { let int i = 0; @@ -15,7 +14,7 @@ fn start(chan[int] c, int start, int number_of_messages) { fn main() -> () { log "Check that we don't deadlock."; let port[int] p = port(); - let task a = spawn "start" start(chan(p), 0, 10); - join a; + let task a = spawn start(chan(p), 0, 10); + task::join(a); log "Joined task"; } \ No newline at end of file diff --git a/src/test/run-pass/task-comm-15.rs b/src/test/run-pass/task-comm-15.rs index 5532cfdd580..58de577e274 100644 --- a/src/test/run-pass/task-comm-15.rs +++ b/src/test/run-pass/task-comm-15.rs @@ -1,6 +1,5 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + fn start(chan[int] c, int n) { let int i = n; @@ -16,6 +15,6 @@ fn main() { // is likely to terminate before the child completes, so from // the child's point of view the receiver may die. We should // drop messages on the floor in this case, and not crash! - auto child = spawn thread "child" start(chan(p), 10); + auto child = spawn start(chan(p), 10); auto c; p |> c; } diff --git a/src/test/run-pass/task-comm-2.rs b/src/test/run-pass/task-comm-2.rs index e856f0bbef2..73d67ef61e3 100644 --- a/src/test/run-pass/task-comm-2.rs +++ b/src/test/run-pass/task-comm-2.rs @@ -1,11 +1,12 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + +use std; + +import std::task; + fn main() -> () { - log "===== SPAWNING and JOINING TASKS ====="; - test00(false); log "===== SPAWNING and JOINING THREAD TASKS ====="; - test00(true); + test00(); } fn start(int task_number) { @@ -17,22 +18,18 @@ fn start(int task_number) { log "Finished task."; } -fn test00(bool create_threads) { +fn test00() { let int number_of_tasks = 8; let int i = 0; let vec[task] tasks = []; while (i < number_of_tasks) { i = i + 1; - if (create_threads) { - tasks += [spawn thread start(i)]; - } else { - tasks += [spawn start(i)]; - } + tasks += [spawn start(i)]; } for (task t in tasks) { - join t; + task::join(t); } log "Joined all task."; diff --git a/src/test/run-pass/task-comm-3.rs b/src/test/run-pass/task-comm-3.rs index 97293102fa8..198d04f44fd 100644 --- a/src/test/run-pass/task-comm-3.rs +++ b/src/test/run-pass/task-comm-3.rs @@ -1,11 +1,11 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + +use std; +import std::task; + fn main() -> () { log "===== WITHOUT THREADS ====="; - test00(false); - log "====== WITH THREADS ======"; - test00(true); + test00(); } fn test00_start(chan[int] ch, int message, int count) { @@ -19,7 +19,7 @@ fn test00_start(chan[int] ch, int message, int count) { log "Ending test00_start"; } -fn test00(bool is_multithreaded) { +fn test00() { let int number_of_tasks = 16; let int number_of_messages = 4; @@ -33,12 +33,7 @@ fn test00(bool is_multithreaded) { // Create and spawn tasks... let vec[task] tasks = []; while (i < number_of_tasks) { - if (is_multithreaded) { - tasks += [ - spawn thread test00_start(ch, i, number_of_messages)]; - } else { - tasks += [spawn test00_start(ch, i, number_of_messages)]; - } + tasks += [spawn test00_start(ch, i, number_of_messages)]; i = i + 1; } @@ -55,7 +50,7 @@ fn test00(bool is_multithreaded) { // Join spawned tasks... for (task t in tasks) { - join t; + task::join(t); } log "Completed: Final number is: "; diff --git a/src/test/run-pass/task-comm-7.rs b/src/test/run-pass/task-comm-7.rs index 5602b742196..9953faf0b4c 100644 --- a/src/test/run-pass/task-comm-7.rs +++ b/src/test/run-pass/task-comm-7.rs @@ -1,6 +1,8 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + +use std; +import std::task; + fn main() -> () { test00(); } @@ -37,10 +39,10 @@ fn test00() { i += 1; } - join t0; - join t1; - join t2; - join t3; + task::join(t0); + task::join(t1); + task::join(t2); + task::join(t3); assert (sum == (((number_of_messages * 4) * ((number_of_messages * 4) - 1)) / 2)); diff --git a/src/test/run-pass/task-comm-8.rs b/src/test/run-pass/task-comm-8.rs index c731456cbfe..9953faf0b4c 100644 --- a/src/test/run-pass/task-comm-8.rs +++ b/src/test/run-pass/task-comm-8.rs @@ -1,6 +1,8 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + +use std; +import std::task; + fn main() -> () { test00(); } @@ -19,14 +21,14 @@ fn test00() { let port[int] p = port(); let int number_of_messages = 10; - let task t0 = spawn thread test00_start(chan(p), - number_of_messages * 0, number_of_messages); - let task t1 = spawn thread test00_start(chan(p), - number_of_messages * 1, number_of_messages); - let task t2 = spawn thread test00_start(chan(p), - number_of_messages * 2, number_of_messages); - let task t3 = spawn thread test00_start(chan(p), - number_of_messages * 3, number_of_messages); + let task t0 = spawn test00_start(chan(p), + number_of_messages * 0, number_of_messages); + let task t1 = spawn test00_start(chan(p), + number_of_messages * 1, number_of_messages); + let task t2 = spawn test00_start(chan(p), + number_of_messages * 2, number_of_messages); + let task t3 = spawn test00_start(chan(p), + number_of_messages * 3, number_of_messages); let int i = 0; while (i < number_of_messages) { @@ -37,10 +39,10 @@ fn test00() { i += 1; } - join t0; - join t1; - join t2; - join t3; + task::join(t0); + task::join(t1); + task::join(t2); + task::join(t3); assert (sum == (((number_of_messages * 4) * ((number_of_messages * 4) - 1)) / 2)); diff --git a/src/test/run-pass/task-comm-9.rs b/src/test/run-pass/task-comm-9.rs index abe5ea81098..3f93537e2d8 100644 --- a/src/test/run-pass/task-comm-9.rs +++ b/src/test/run-pass/task-comm-9.rs @@ -1,6 +1,8 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + +use std; +import std::task; + fn main() -> () { test00(); } @@ -19,7 +21,7 @@ fn test00() { let port[int] p = port(); let int number_of_messages = 10; - let task t0 = spawn thread "child" + let task t0 = spawn test00_start(chan(p), number_of_messages); let int i = 0; @@ -28,7 +30,7 @@ fn test00() { i += 1; } - join t0; + task::join(t0); assert (sum == (number_of_messages * (number_of_messages - 1)) / 2); } \ No newline at end of file diff --git a/src/test/run-pass/task-comm.rs b/src/test/run-pass/task-comm.rs index 3a3d7d5942d..16d255ab046 100644 --- a/src/test/run-pass/task-comm.rs +++ b/src/test/run-pass/task-comm.rs @@ -1,9 +1,11 @@ // xfail-stage0 -// xfail-stage1 -// xfail-stage2 + +use std; + +import std::task; fn main() -> () { - test00(true); + test00(); // test01(); test02(); test03(); @@ -23,7 +25,7 @@ fn test00_start(chan[int] ch, int message, int count) { log "Ending test00_start"; } -fn test00(bool is_multithreaded) { +fn test00() { let int number_of_tasks = 1; let int number_of_messages = 4; log "Creating tasks"; @@ -36,12 +38,7 @@ fn test00(bool is_multithreaded) { let vec[task] tasks = []; while (i < number_of_tasks) { i = i + 1; - if (is_multithreaded) { - tasks += [ - spawn thread test00_start(ch, i, number_of_messages)]; - } else { - tasks += [spawn test00_start(ch, i, number_of_messages)]; - } + tasks += [spawn test00_start(ch, i, number_of_messages)]; } let int sum = 0; @@ -55,7 +52,7 @@ fn test00(bool is_multithreaded) { } for (task t in tasks) { - join t; + task::join(t); } log "Completed: Final number is: "; @@ -89,9 +86,9 @@ obj vector(mutable int x, int y) { fn test03() { log "Creating object ..."; - let mutable vector v = vector(1, 2); + let vector v = vector(1, 2); log "created object ..."; - let mutable vector t = v; + let vector t = v; log v.length(); } @@ -109,7 +106,7 @@ fn test04() { let int i = 4; while (i > 0) { i = i - 1; - spawn thread test04_start(); + spawn test04_start(); } log "Finishing up."; } @@ -125,7 +122,7 @@ fn test05_start(chan[int] ch) { fn test05() { let port[int] po = port(); let chan[int] ch = chan(po); - spawn thread test05_start(ch); + spawn test05_start(ch); let int value; po |> value; po |> value; po |> value; @@ -150,12 +147,11 @@ fn test06() { let vec[task] tasks = []; while (i < number_of_tasks) { i = i + 1; - tasks += [spawn thread test06_start(i)]; - // tasks += [spawn test06_start(i)]; + tasks += [spawn test06_start(i)]; } for (task t in tasks) { - join t; + task::join(t); } }