Created proper 'docs' folder for new layout.

1 files changed, 67 insertions, 0 deletions

diff --git a/docs/examples/pilib/twoPlaceBuffer.scala b/docs/examples/pilib/twoPlaceBuffer.scala
new file mode 100644
index 0000000000..686547b344
--- /dev/null
+++ b/docs/examples/pilib/twoPlaceBuffer.scala
@@ -0,0 +1,67 @@
+package examples.pilib;
+
+import scala.concurrent.pilib._;
+
+/** Two-place buffer specification and implementation. */
+object twoPlaceBuffer with Application {
+
+  /**
+  * Specification.
+  */
+  def Spec[a](in: Chan[a], out: Chan[a]): unit =  {
+
+    def B0: unit = choice (
+      in * (x => B1(x))
+    );
+
+    def B1(x: a): unit = choice (
+      out(x) * (B0),
+      in * (y => B2(x, y))
+    );
+
+    def B2(x: a, y: a): unit = choice (
+      out(x) * (B1(y))
+    );
+
+    B0
+  }
+
+  /**
+  * Implementation using two one-place buffers.
+  */
+  def Impl[a](in: Chan[a], out: Chan[a]): unit =  {
+    ///- ... complete here ...
+    // one-place buffer
+    def OnePlaceBuffer[a](in: Chan[a], out: Chan[a]): unit =  {
+      def B0: unit = choice ( in * (x => B1(x)) );
+      def B1(x: a): unit = choice ( out(x) * (B0));
+      B0
+    }
+    val hidden = new Chan[a];
+    spawn < OnePlaceBuffer(in, hidden) | OnePlaceBuffer(hidden, out) >
+    ///+
+  }
+
+  val random = new java.util.Random();
+
+  def Producer(n: Int, in: Chan[String]): unit = {
+    Thread.sleep(random.nextInt(1000));
+    val msg = "" + n;
+    choice (in(msg) * {});
+    Producer(n + 1, in)
+  }
+
+  def Consumer(out: Chan[String]): unit = {
+    Thread.sleep(random.nextInt(1000));
+    choice (out * { msg => () });
+    Consumer(out)
+  }
+
+  val in = new Chan[String];
+  in.attach(s => System.out.println("put " + s));
+  val out = new Chan[String];
+  out.attach(s => System.out.println("get " + s));
+  //spawn < Producer(0, in) | Consumer(out) | Spec(in, out) >
+  spawn < Producer(0, in) | Consumer(out) | Impl(in, out) >
+
+}