---

yaml
---
r: 22672
b: refs/heads/master
c: b30a58a
h: refs/heads/master
v: v3

Author: bblum

[refs]

@@ -1,5 +1,5 @@
 ---
-refs/heads/master: e0e9e451e7b102f53bd9d86b638d9c5d7fae3cc8
+refs/heads/master: b30a58abe24643bdad8473850945f46927fb186b
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: cd6f24f9d14ac90d167386a56e7a6ac1f0318195
 refs/heads/try: ffbe0e0e00374358b789b0037bcb3a577cd218be

trunk/src/test/bench/msgsend-pipes-shared.rs

@@ -57,10 +57,10 @@ fn run(args: &[~str]) {
     let start = std::time::precise_time_s();
     let mut worker_results = ~[];
     for uint::range(0u, workers) |i| {
-        let builder = task::builder();
-        vec::push(worker_results, task::future_result(builder));
         let to_child = to_child.clone();
-        do task::run(builder) {
+        do task::task().future_result(|-r| {
+            vec::push(worker_results, r);
+        }).spawn {
             for uint::range(0u, size / workers) |_i| {
                 //#error("worker %?: sending %? bytes", i, num_bytes);
                 to_child.send(bytes(num_bytes));

trunk/src/test/bench/msgsend-pipes.rs

@@ -52,11 +52,11 @@ fn run(args: &[~str]) {
     let start = std::time::precise_time_s();
     let mut worker_results = ~[];
     for uint::range(0u, workers) |i| {
-        let builder = task::builder();
-        vec::push(worker_results, task::future_result(builder));
         let (to_child, from_parent_) = pipes::stream();
         from_parent.add(from_parent_);
-        do task::run(builder) {
+        do task::task().future_result(|-r| {
+            vec::push(worker_results, r);
+        }).spawn {
             for uint::range(0u, size / workers) |_i| {
                 //#error("worker %?: sending %? bytes", i, num_bytes);
                 to_child.send(bytes(num_bytes));

trunk/src/test/bench/msgsend.rs

@@ -39,9 +39,9 @@ fn run(args: ~[~str]) {
     let to_child = to_child;
     let mut worker_results = ~[];
     for uint::range(0u, workers) |_i| {
-        let builder = task::builder();
-        vec::push(worker_results, task::future_result(builder));
-        do task::run(builder) {
+        do task::task().future_result(|-r| {
+            vec::push(worker_results, r);
+        }).spawn {
             for uint::range(0u, size / workers) |_i| {
                 comm::send(to_child, bytes(100u));
             }

trunk/src/test/bench/shootout-pfib.rs

@@ -71,9 +71,11 @@ fn stress_task(&&id: int) {
 fn stress(num_tasks: int) {
     let mut results = ~[];
     for range(0, num_tasks) |i| {
-        let builder = task::builder();
-        results += ~[task::future_result(builder)];
-        task::run(builder, || stress_task(i) );
+        do task::task().future_result(|-r| {
+            results += ~[r];
+        }).spawn {
+            stress_task(i);
+        }
     }
     for results.each |r| { future::get(r); }
 }

trunk/src/test/bench/task-perf-word-count.rs

@@ -62,9 +62,11 @@ mod map_reduce {
        ~[future::future<task::task_result>] {
         let mut results = ~[];
         for inputs.each |i| {
-            let builder = task::builder();
-            results += ~[task::future_result(builder)];
-            task::run(builder, || map_task(ctrl, i));
+            do task::task().future_result(|-r| {
+                results += ~[r]; // Add result for this task to the list
+            }).spawn {
+                map_task(ctrl, i); // Task body
+            }
         }
         ret results;
     }
@@ -160,9 +162,11 @@ mod map_reduce {
                     // log(error, "creating new reducer for " + k);
                     let p = port();
                     let ch = chan(p);
-                    let builder = task::builder();
-                    results += ~[task::future_result(builder)];
-                    task::run(builder, || reduce_task(k, ch) );
+                    do task::task().future_result(|-r| {
+                        results += ~[r]; // Add result for this task
+                    }).spawn {
+                        reduce_task(k, ch); // Task body
+                    }
                     c = recv(p);
                     reducers.insert(k, c);
                   }

trunk/src/test/run-pass/osmain.rs

@@ -14,29 +14,9 @@ fn run(i: int) {
         ret;
     }
 
-    let builder = task::builder();
-    let opts = {
-        sched: some({
-            mode: task::osmain,
-            foreign_stack_size: none
-        })
-        with task::get_opts(builder)
-    };
-    task::set_opts(builder, opts);
-    task::unsupervise(builder);
-    do task::run(builder) {
+    do task::task().sched_mode(task::osmain).unlinked().spawn {
         task::yield();
-        let builder = task::builder();
-        let opts = {
-            sched: some({
-                mode: task::single_threaded,
-                foreign_stack_size: none
-            })
-            with task::get_opts(builder)
-        };
-        task::set_opts(builder, opts);
-        task::unsupervise(builder);
-        do task::run(builder) {
+        do task::task().sched_mode(task::single_threaded).unlinked().spawn {
             task::yield();
             run(i - 1);
             task::yield();

trunk/src/test/run-pass/task-comm-12.rs

@@ -7,9 +7,10 @@ fn start(&&task_number: int) { #debug("Started / Finished task."); }
 
 fn test00() {
     let i: int = 0;
-    let builder = task::builder();
-    let r = task::future_result(builder);
-    task::run(builder, || start(i) );
+    let mut result = none;
+    do task::task().future_result(|-r| { result = some(r); }).spawn {
+        start(i)
+    }
 
     // Sleep long enough for the task to finish.
     let mut i = 0;
@@ -19,7 +20,7 @@ fn test00() {
     }
 
     // Try joining tasks that have already finished.
-    future::get(r);
+    future::get(option::unwrap(result));
 
     #debug("Joined task.");
 }

trunk/src/test/run-pass/task-comm-3.rs

@@ -32,9 +32,9 @@ fn test00() {
     // Create and spawn tasks...
     let mut results = ~[];
     while i < number_of_tasks {
-        let builder = task::builder();
-        results += ~[task::future_result(builder)];
-        do task::run(builder) |copy i| {
+        do task::task().future_result(|-r| {
+            results += ~[r];
+        }).spawn |copy i| {
             test00_start(ch, i, number_of_messages)
         }
         i = i + 1;

trunk/src/test/run-pass/task-comm-9.rs

@@ -16,9 +16,8 @@ fn test00() {
     let number_of_messages: int = 10;
     let ch = comm::chan(p);
 
-    let builder = task::builder();
-    let r = task::future_result(builder);
-    do task::run(builder) {
+    let mut result = none;
+    do task::task().future_result(|-r| { result = some(r); }).spawn {
         test00_start(ch, number_of_messages);
     }
 
@@ -29,7 +28,7 @@ fn test00() {
         i += 1;
     }
 
-    future::get(r);
+    future::get(option::unwrap(result));
 
     assert (sum == number_of_messages * (number_of_messages - 1) / 2);
 }

trunk/src/test/run-pass/task-comm.rs

@@ -41,9 +41,9 @@ fn test00() {
     let mut results = ~[];
     while i < number_of_tasks {
         i = i + 1;
-        let builder = task::builder();
-        results += ~[task::future_result(builder)];
-        do task::run(builder) |copy i| {
+        do task::task().future_result(|-r| {
+            results += ~[r];
+        }).spawn |copy i| {
             test00_start(ch, i, number_of_messages);
         }
     }
@@ -128,9 +128,9 @@ fn test06() {
     let mut results = ~[];
     while i < number_of_tasks {
         i = i + 1;
-        let builder = task::builder();
-        results += ~[task::future_result(builder)];
-        do task::run(builder) |copy i| {
+        do task::task().future_result(|-r| {
+            results += ~[r];
+        }).spawn |copy i| {
             test06_start(i);
         };
     }

trunk/src/test/run-pass/yield.rs

@@ -4,15 +4,14 @@ import task;
 import task::*;
 
 fn main() {
-    let builder = task::builder();
-    let result = task::future_result(builder);
-    task::run(builder, || child() );
+    let mut result = none;
+    task::task().future_result(|-r| { result = some(r); }).spawn(child);
     #error("1");
     yield();
     #error("2");
     yield();
     #error("3");
-    future::get(result);
+    future::get(option::unwrap(result));
 }
 
 fn child() {

trunk/src/test/run-pass/yield1.rs

@@ -4,12 +4,11 @@ import task;
 import task::*;
 
 fn main() {
-    let builder = task::builder();
-    let result = task::future_result(builder);
-    task::run(builder, || child() );
+    let mut result = none;
+    task::task().future_result(|-r| { result = some(r); }).spawn(child);
     #error("1");
     yield();
-    future::get(result);
+    future::get(option::unwrap(result));
 }
 
 fn child() { #error("2"); }