Finish monitor API, add ObjectPipe for moritz++

lib/Threads.pm6

@@ -2,22 +2,55 @@ module Threads;
 
 # Should be a role, since it can be applied to any class with minimal overhead
 class Monitor is export {
-    method enter() {
-        Q:CgOp {
-            (rnull (rawscall System.Threading.Monitor.Enter (@ {self})))
-        }
-    }
-    method exit() {
-        Q:CgOp {
-            (rnull (rawscall System.Threading.Monitor.Exit (@ {self})))
-        }
-    }
+    method enter() { Q:CgOp {
+        (rnull (rawscall System.Threading.Monitor.Enter (@ {self})))
+    } }
+    method exit() { Q:CgOp {
+        (rnull (rawscall System.Threading.Monitor.Exit (@ {self})))
+    } }
+    method pulse() { Q:CgOp {
+        (rnull (rawscall System.Threading.Monitor.Pulse (@ {self})))
+    } }
+    method pulse_all() { Q:CgOp {
+        (rnull (rawscall System.Threading.Monitor.PulseAll (@ {self})))
+    } }
+    method try_enter($t) { Q:CgOp {
+        (box Bool (rawscall System.Threading.Monitor.TryEnter (@ {self})
+            (cast int (obj_getnum {$t * 1000}))))
+    } }
+    method wait() { Q:CgOp {
+        (box Bool (rawscall System.Threading.Monitor.Wait (@ {self})))
+    } }
+    method try_wait($t) { Q:CgOp {
+        (box Bool (rawscall System.Threading.Monitor.Wait (@ {self})
+            (cast int (obj_getnum {$t * 1000}))))
+    } }
     # TODO exception handling
     method lock($f) { self.enter; $f(); self.exit }
 }
 
 sub lock($m,$f) is export { $m.lock($f); }
 
+class ObjectPipe {
+    has $!lock = Monitor.new;
+    has $!queue = [];
+
+    method get() {
+        $!lock.enter;
+        $!lock.wait until $!queue;
+        my $value = shift $!queue;
+        $!lock.exit;
+        $value;
+    }
+
+    method put($x) {
+        $!lock.enter;
+        push $!queue, $x;
+        $!lock.pulse;
+        $!lock.exit;
+    }
+}
+
 class Thread is export {
     has $!value;
     method new($func) {