---

yaml
---
r: 14321
b: refs/heads/try
c: 0438e6e
h: refs/heads/master
i:
  14319: 9efc0d0
v: v3

Author: brson

[refs]

@@ -2,5 +2,5 @@
 refs/heads/master: 61b1875c16de39c166b0f4d54bba19f9c6777d1a
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
-refs/heads/try: 1248c250d86af96a9c4f3ee1468d9dead10ac41b
+refs/heads/try: 0438e6e924f09453dceff010bb4264568afa35a0
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/try/src/test/bench/task-perf-one-million.rs

@@ -0,0 +1,68 @@
+// Test for concurrent tasks
+
+enum msg {
+    ready(comm::chan<msg>),
+    start,
+    done(int),
+}
+
+fn calc(children: uint, parent_ch: comm::chan<msg>) {
+    let port = comm::port();
+    let chan = comm::chan(port);
+    let child_chs = [];
+    let sum = 0;
+
+    iter::repeat (children) {||
+        task::spawn {||
+            calc(0u, chan);
+        };
+    }
+
+    iter::repeat (children) {||
+        alt check comm::recv(port) {
+          ready(child_ch) {
+            child_chs += [child_ch];
+          }
+        }
+    }
+
+    comm::send(parent_ch, ready(chan));
+
+    alt check comm::recv(port) {
+        start {
+          vec::iter (child_chs) { |child_ch|
+              comm::send(child_ch, start);
+          }
+        }
+    }
+
+    iter::repeat (children) {||
+        alt check comm::recv(port) {
+          done(child_sum) { sum += child_sum; }
+        }
+    }
+
+    comm::send(parent_ch, done(sum + 1));
+}
+
+fn main(args: [str]) {
+    let children = if vec::len(args) == 2u {
+        uint::from_str(args[1])
+    } else {
+        100u
+    };
+    let port = comm::port();
+    let chan = comm::chan(port);
+    task::spawn {||
+        calc(children, chan);
+    };
+    alt check comm::recv(port) {
+      ready(chan) {
+        comm::send(chan, start);
+      }
+    }
+    let sum = alt check comm::recv(port) {
+      done(sum) { sum }
+    };
+    #error("How many tasks? %d tasks.", sum);
+}