Scala example source code file (ExecutorScheduler.scala)

This example Scala source code file (ExecutorScheduler.scala) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Scala source code examples by using tags.

All credit for the original source code belongs to scala-lang.org; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Scala tags/keywords

actor, actors, concurrent, executorscheduler, executorservice, for, guide, ischeduler, migration, runnable, unit, use

The ExecutorScheduler.scala Scala example source code

/*                     __                                               *\
**     ________ ___   / /  ___     Scala API                            **
**    / __/ __// _ | / /  / _ |    (c) 2005-2013, LAMP/EPFL             **
**  __\ \/ /__/ __ |/ /__/ __ |    http://scala-lang.org/               **
** /____/\___/_/ |_/____/_/ | |                                         **
**                          |/                                          **
\*                                                                      */


package scala.actors
package scheduler

import java.util.concurrent.{Callable, ExecutorService}
import scala.concurrent.ThreadPoolRunner

/**
 * The <code>ExecutorScheduler</code> object is used to create
 * <code>ExecutorScheduler</code> instances.
 *
 * @author Philipp Haller
 */
@deprecated("Use the akka.actor package instead. For migration from the scala.actors package refer to the Actors Migration Guide.", "2.11.0")
object ExecutorScheduler {

  private def start(sched: ExecutorScheduler): ExecutorScheduler = {
    sched.start()
    sched
  }

  /** Creates an <code>ExecutorScheduler</code> using the provided
   *  <code>ExecutorService</code>.
   *
   *  @param  exec the executor to use
   *  @return      the scheduler
   */
  def apply(exec: ExecutorService): ExecutorScheduler =
    start(new ExecutorScheduler {
      val executor: ExecutorService = exec
    })

  /** Creates an <code>ExecutorScheduler</code> using the provided
   *  <code>ExecutorService</code>.
   *
   *  @param  exec the executor to use
   *  @param  term whether the scheduler should automatically terminate
   *  @return      the scheduler
   */
  def apply(exec: ExecutorService, term: Boolean): ExecutorScheduler =
    start(new ExecutorScheduler {
      val executor: ExecutorService = exec
      override val terminate = term
    })

}

/**
 * The <code>ExecutorScheduler</code> class uses an
 * <code>ExecutorService</code> to execute <code>Actor</code>s.
 *
 * @author Philipp Haller
 */
@deprecated("Use the akka.actor package instead. For migration from the scala.actors package refer to the Actors Migration Guide.", "2.11.0")
trait ExecutorScheduler extends Thread
                        with IScheduler with TerminationService
                        with ThreadPoolRunner {

  def execute(task: Runnable) {
    super[ThreadPoolRunner].execute(task.asInstanceOf[Task[Unit]])
  }

  private class RunCallable(fun: => Unit) extends Callable[Unit] with Runnable {
    def call() { fun }
    def run() { fun }
  }

  /** Submits a closure for execution.
   *
   *  @param  fun  the closure to be executed
   */
  override def execute(fun: => Unit) {
    super[ThreadPoolRunner].execute((new RunCallable(fun)).asInstanceOf[Task[Unit]])
  }

  /** This method is called when the scheduler shuts down.
   */
  def onShutdown(): Unit =
    executor.shutdown()

  /** The scheduler is active if the underlying <code>ExecutorService</code>
   *  has not been shut down.
   */
  def isActive =
    (executor ne null) && !executor.isShutdown

}