---

yaml
---
r: 8071
b: refs/heads/snap-stage3
c: cdb246f
h: refs/heads/master
i:
  8069: a713c74
  8067: 6a74b03
  8063: 71d5518
v: v3

Author: brson

[refs]

@@ -1,6 +1,6 @@
 ---
 refs/heads/master: 2898dcc5d97da9427ac367542382b6239d9c0bbf
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
-refs/heads/snap-stage3: e81840607266d8c9af6ac5ddf187174c4689e26b
+refs/heads/snap-stage3: cdb246f832a8dcecbd5305a4c256c04e1e266a0a
 refs/heads/try: 2898dcc5d97da9427ac367542382b6239d9c0bbf
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/snap-stage3/src/test/bench/shootout-threadring.rs

@@ -0,0 +1,53 @@
+// Based on threadring.erlang by Jira Isa
+use std;
+
+// FIXME: Need a cleaner way to request the runtime to exit
+#[nolink]
+native mod libc {
+    fn exit(status: ctypes::c_int);
+}
+
+const n_threads: int = 503;
+
+fn start(+token: int) {
+    import iter::*;
+
+    let p = comm::port();
+    let ch = iter::foldl(bind int::range(2, n_threads + 1, _),
+                         comm::chan(p)) { |ch, i|
+        // FIXME: Some twiddling because we don't have a standard
+        // reverse range function yet
+        let id = n_threads + 2 - i;
+        let {to_child, _} = task::spawn_connected::<int, int> {|p, _ch|
+            roundtrip(id, p, ch)
+        };
+        to_child
+    };
+    comm::send(ch, token);
+    roundtrip(1, p, ch);
+}
+
+fn roundtrip(id: int, p: comm::port<int>, ch: comm::chan<int>) {
+    while (true) {
+        alt comm::recv(p) {
+          1 {
+            std::io::println(#fmt("%d\n", id));
+            libc::exit(0i32);
+          }
+          token {
+            #debug("%d %d", id, token);
+            comm::send(ch, token - 1);
+          }
+        }
+    }
+}
+
+fn main(args: [str]) {
+    let token = if vec::len(args) < 2u {
+        1000
+    } else {
+        int::from_str(args[1])
+    };
+
+    start(token);
+}