From 37da2899f40661e3e9631e497da8dc59b971cbd0 Mon Sep 17 00:00:00 2001
From: "Charles.Forsyth" <devnull@localhost>
Date: Fri, 22 Dec 2006 17:07:39 +0000
Subject: 20060303a

---
 appl/lib/watchvars.b | 44 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 44 insertions(+)
 create mode 100644 appl/lib/watchvars.b

(limited to 'appl/lib/watchvars.b')

diff --git a/appl/lib/watchvars.b b/appl/lib/watchvars.b
new file mode 100644
index 00000000..ad6c6947
--- /dev/null
+++ b/appl/lib/watchvars.b
@@ -0,0 +1,44 @@
+implement Watchvars;
+include "watchvars.m";
+
+Watchvar[T].new(v: T): Watchvar
+{
+	e := Watchvar[T](chan[1] of (T, chan of T));
+	e.c <-= (v, chan[1] of T);
+	return e;
+}
+
+Watchvar[T].get(e: self Watchvar): T
+{
+	(v, ic) := <-e.c;
+	e.c <-= (v, ic);
+	return v;
+}
+
+Watchvar[T].set(e: self Watchvar, v: T)
+{
+	(ov, ic) := <-e.c;
+	ic <-= v;
+	e.c <-= (v, chan[1] of T);
+}
+
+Watchvar[T].wait(e: self Watchvar): T
+{
+	(v, ic) := <-e.c;
+	e.c <-= (v, ic);
+	v = <-ic;
+	ic <-= v;
+	return v;
+}
+
+Watchvar[T].waitc(e: self Watchvar): (T, chan of T)
+{
+	vic := <-e.c;
+	e.c <-= vic;
+	return vic;
+}
+
+Watchvar[T].waited(nil: self Watchvar, ic: chan of T, v: T)
+{
+	ic <-= v;
+}
-- 
cgit v1.2.3