summaryrefslogtreecommitdiff
path: root/docs/examples/computeserver.scala
diff options
context:
space:
mode:
authorGilles Dubochet <gilles.dubochet@epfl.ch>2005-12-16 18:44:33 +0000
committerGilles Dubochet <gilles.dubochet@epfl.ch>2005-12-16 18:44:33 +0000
commit53a3cc7b17f4cf97075b7e71720777fd84109696 (patch)
tree0cc784e0b47ea49cc151a136d19f20bfa8ee2197 /docs/examples/computeserver.scala
parentdf50e05006b43b007c2587549030d24b5c154398 (diff)
downloadscala-53a3cc7b17f4cf97075b7e71720777fd84109696.tar.gz
scala-53a3cc7b17f4cf97075b7e71720777fd84109696.tar.bz2
scala-53a3cc7b17f4cf97075b7e71720777fd84109696.zip
Created proper 'docs' folder for new layout.
Diffstat (limited to 'docs/examples/computeserver.scala')
-rw-r--r--docs/examples/computeserver.scala42
1 files changed, 42 insertions, 0 deletions
diff --git a/docs/examples/computeserver.scala b/docs/examples/computeserver.scala
new file mode 100644
index 0000000000..acc4a0b93e
--- /dev/null
+++ b/docs/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](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())
+}