Checked in examples for new actors lib.

1 files changed, 33 insertions, 0 deletions

diff --git a/docs/examples/actors/BoundedBufferTest.scala b/docs/examples/actors/BoundedBufferTest.scala
new file mode 100644
index 0000000000..5a04f7aafd
--- /dev/null
+++ b/docs/examples/actors/BoundedBufferTest.scala
@@ -0,0 +1,33 @@
+package examples.actors
+
+import scala.actors.Actor._
+
+class BoundedBuffer[T](N: int) {
+  private case class Get
+  private case class Put(x: T)
+
+  private val buffer = actor {
+    val buf = new Array[T](N)
+    var in = 0; var out = 0; var n = 0
+    while(true) {
+      receive {
+        case Put(x) if n < N =>
+          buf(in) = x; in = (in + 1) % N; n = n + 1; reply()
+        case Get() if n > 0 =>
+          val r = buf(out); out = (out + 1) % N; n = n - 1; reply(r)
+      }
+    }
+  }
+
+  def put(x: T): Unit = buffer !? Put(x)
+
+  def get: T = (buffer !? Get()).asInstanceOf[T]
+}
+
+object BoundedBufferTest {
+  def main(args: Array[String]) = {
+    val buf = new BoundedBuffer[Int](1)
+    buf.put(42)
+    scala.Console.println("" + buf.get)
+  }
+}