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()) }