From d5da7d9aa5a8d4833775454853e81ead20cc37a7 Mon Sep 17 00:00:00 2001 From: Martin Odersky Date: Mon, 10 Mar 2003 11:55:36 +0000 Subject: *** empty log message *** --- sources/examples/ComputeServer.scala | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 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..e322860b78 --- /dev/null +++ b/sources/examples/ComputeServer.scala @@ -0,0 +1,32 @@ +package examples; + +import concurrent._, concurrent.ops._; + +class ComputeServer(n: Int) { + private trait Job { + type t; + def task: t; + def return(x: t): Unit; + } + + private val openJobs = new Channel[Job](); + + private def processor(i: Int): Unit { + while (True) { + val job = openJobs.read; + job.return(job.task) + } + } + def future[a](def p: a): () => a { + val reply = new SyncVar[a](); + openJobs.write{ + new Job with { + type t = a; + def task = p; + def return(x: a) = reply.set(x); + } + } + () => reply.get + } + replicate(1,n){processor} +} -- cgit v1.2.3