Added a message passing system based on lock free queues for inter-thread communication. Channels now buffer on the sending side, and no longer require blocking when sending. Lots of other refactoring and bug fixes.

1 files changed, 19 insertions, 0 deletions

diff --git a/src/test/run-pass/task-comm-0.rs b/src/test/run-pass/task-comm-0.rs
new file mode 100644
index 00000000..5992ba5c
--- /dev/null
+++ b/src/test/run-pass/task-comm-0.rs
@@ -0,0 +1,19 @@
+io fn main() -> () {
+    test05();
+}
+
+io fn test05_start(chan[int] ch) {
+    ch <| 10;
+    ch <| 20;
+    ch <| 30;
+}
+
+io fn test05() {
+    let port[int] po = port();
+    let chan[int] ch = chan(po);
+    spawn test05_start(chan(po));
+    let int value <- po;
+    value <- po;
+    value <- po;
+    log value;
+}