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