computeserver.scala

JAVA 语言的函数式编程扩展

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
      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 extends Application {

  def kill(delay: Int) = new java.util.Timer().schedule(
    new java.util.TimerTask {
      override def run() = {
        println("[killed]")
        System.exit(0)
      }
    },
    delay) // in milliseconds

  val server = new ComputeServer(1)
  val f = server.future(42)
  println(f())
  kill(10000)
}