From d15a4148ef955469477097129f442d61a6f21116 Mon Sep 17 00:00:00 2001
From: michelou <michelou@epfl.ch>
Date: Wed, 25 Feb 2004 12:32:58 +0000
Subject: - renamed to 'computeserver.scala'.

---
 sources/examples/computeserver.scala | 42 ++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 sources/examples/computeserver.scala

(limited to 'sources/examples/computeserver.scala')

diff --git a/sources/examples/computeserver.scala b/sources/examples/computeserver.scala
new file mode 100644
index 0000000000..f86f41e3ff
--- /dev/null
+++ b/sources/examples/computeserver.scala
@@ -0,0 +1,42 @@
+package examples;
+
+import concurrent._, concurrent.ops._;
+
+class ComputeServer(n: Int) {
+
+  private trait Job {
+    type t;
+    def task: t;
+    def ret(x: t): Unit;
+  }
+
+  private val openJobs = new Channel[Job]();
+
+  private def processor(i: Int): Unit = {
+    while (true) {
+      val job = openJobs.read;
+      Console.println("read a job");
+      job.ret(job.task)
+    }
+  }
+
+  def future[a](def p: a): () => a = {
+    val reply = new SyncVar[a]();
+    openJobs.write{
+      new Job {
+	type t = a;
+	def task = p;
+	def ret(x: a) = reply.set(x);
+      }
+    }
+    () => reply.get
+  }
+
+  spawn(replicate(0, n) { processor })
+}
+
+object computeserver with Application {
+  val server = new ComputeServer(1);
+  val f = server.future(42);
+  Console.println(f())
+}
-- 
cgit v1.2.3