java good code

1 Executor.scala

 // Start worker thread pool

  val threadPool = new ThreadPoolExecutor(

    1, 128, 600, TimeUnit.SECONDS, new SynchronousQueue[Runnable])

  def launchTask(context: ExecutorBackend, taskId: Long, serializedTask: ByteBuffer) {

    threadPool.execute(new TaskRunner(context, taskId, serializedTask))

  }

  class TaskRunner(context: ExecutorBackend, taskId: Long, serializedTask: ByteBuffer)

    extends Runnable {

    override def run() {

2