From 96ae92e4f6f830a9a4e55768c3de0328a2a030ba Mon Sep 17 00:00:00 2001 From: michelou Date: Wed, 22 Feb 2006 17:54:31 +0000 Subject: adapted code to Scala 2 syntax in files src/exa... adapted code to Scala 2 syntax in files src/examples/**/*.scala --- docs/examples/computeserver.scala | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) (limited to 'docs/examples/computeserver.scala') diff --git a/docs/examples/computeserver.scala b/docs/examples/computeserver.scala index acc4a0b93e..7e63455258 100644 --- a/docs/examples/computeserver.scala +++ b/docs/examples/computeserver.scala @@ -5,28 +5,28 @@ import concurrent._, concurrent.ops._; class ComputeServer(n: Int) { private trait Job { - type t; - def task: t; - def ret(x: t): Unit; + type t + def task: t + def ret(x: t): Unit } - private val openJobs = new Channel[Job](); + private val openJobs = new Channel[Job]() private def processor(i: Int): Unit = { while (true) { - val job = openJobs.read; - Console.println("read a job"); + val job = openJobs.read + Console.println("read a job") job.ret(job.task) } } def future[a](p: => a): () => a = { - val reply = new SyncVar[a](); + val reply = new SyncVar[a]() openJobs.write{ new Job { - type t = a; - def task = p; - def ret(x: a) = reply.set(x); + type t = a + def task = p + def ret(x: a) = reply.set(x) } } () => reply.get @@ -35,8 +35,8 @@ class ComputeServer(n: Int) { spawn(replicate(0, n) { processor }) } -object computeserver with Application { - val server = new ComputeServer(1); - val f = server.future(42); +object computeserver extends Application { + val server = new ComputeServer(1) + val f = server.future(42) Console.println(f()) } -- cgit v1.2.3