summaryrefslogtreecommitdiff
path: root/sources/examples
diff options
context:
space:
mode:
Diffstat (limited to 'sources/examples')
-rw-r--r--sources/examples/buffer1.scala46
1 files changed, 0 insertions, 46 deletions
diff --git a/sources/examples/buffer1.scala b/sources/examples/buffer1.scala
deleted file mode 100644
index 2afb4377bf..0000000000
--- a/sources/examples/buffer1.scala
+++ /dev/null
@@ -1,46 +0,0 @@
-package examples;
-
-object buffer1 {
-
- import scala.concurrent._;
-
- class OnePlaceBuffer {
- private val m = new MailBox(); // An internal mailbox
- private case class Empty(), Full(x: Int); // Types of messages we deal with
-
- m send Empty(); // Initialization
-
- def write(x: Int): Unit = m receive {
- case Empty() =>
- Console.println("put " + x);
- m send Full(x)
- }
-
- def read: Int = m receive {
- case Full(x) =>
- Console.println("get " + x);
- m send Empty() ; x
- }
- }
-
- def main(args: Array[String]) = {
- val buf = new OnePlaceBuffer;
- val random = new java.util.Random();
-
- def producer(n: int): unit = {
- Thread.sleep(random.nextInt(1000));
- buf.write(n);
- producer(n + 1)
- }
-
- def consumer: unit = {
- Thread.sleep(random.nextInt(1000));
- val n = buf.read;
- consumer
- }
-
- ops.spawn(producer(0));
- ops.spawn(consumer)
- }
-
-}