Custom shutdown in a Runnable

RunnableWithShutdown.scala

package com.datasift.playback

import java.util.concurrent.Executors

class RunnableWithShutdown extends MyRunnable {

  @volatile
  var isShutDown = false

  override def shutdown() { isShutDown = true }

  override def run() {
    while(!isShutDown) {
      // Do Something
    }
  }
}


trait MyRunnable extends Runnable {
  def shutdown()
}

class ThreadTest extends App {

  val executor = Executors.newFixedThreadPool(3)
  val myThreads = for (i <- 1 to 3) yield new RunnableWithShutdown
  executor.submit(new MyThread)

  myThreads foreach { _.shutdown }
  executor.shutdown()
}