alternate Threaded

Threaded.scala

trait Threaded[T] extends Runnable {

  @volatile private var stopping = false
  @volatile private var thread: Thread = _

  def afterPropertiesSet() {
    thread = new Thread(this)
    thread.start()
  }

  def destroy() {
    stopping = true
    thread.interrupt()
  }

  def run {
    val t = before()
    Repeat.until(stopping) { task(t) } {
      handling(classOf[InterruptedException]) by { t => stopping = true }
    }
    after(t)
  }

  def task(t: T): Unit
  def before(): T
  def after(t: T): Unit
}

object Repeat {
  def until(finished: => Boolean)(task: => Unit)(handlers: Catch[Unit]) = {
    @annotation.tailrec
    def loop {
      if (!finished) {
        handlers apply task
        loop
      }
    }
    loop
  }
}