|
Scala example source code file (Scheduler.scala)
The Scala Scheduler.scala source code/* __ *\ ** ________ ___ / / ___ Scala API ** ** / __/ __// _ | / / / _ | (c) 2005-2011, LAMP/EPFL ** ** __\ \/ /__/ __ |/ /__/ __ | http://scala-lang.org/ ** ** /____/\___/_/ |_/____/_/ | | ** ** |/ ** \* */ package scala.actors import java.util.concurrent._ import scheduler.{DelegatingScheduler, ForkJoinScheduler, ResizableThreadPoolScheduler, ThreadPoolConfig} /** * Used by [[scala.actors.Actor]] instances to * execute tasks of an actor execution. * * @author Philipp Haller */ object Scheduler extends DelegatingScheduler { Debug.info("initializing "+this+"...") def makeNewScheduler: IScheduler = { val sched = if (!ThreadPoolConfig.useForkJoin) { // default is non-daemon val s = new ResizableThreadPoolScheduler(false) s.start() s } else { // default is non-daemon, fair val s = new ForkJoinScheduler s.start() s } Debug.info(this+": starting new "+sched+" ["+sched.getClass+"]") sched } /* Only <code>ForkJoinScheduler implements this method. */ @deprecated("snapshot will be removed", "2.8.0") def snapshot() { if (sched.isInstanceOf[ForkJoinScheduler]) { sched.asInstanceOf[ForkJoinScheduler].snapshot() } else sys.error("scheduler does not implement snapshot") } /* Only <code>ForkJoinScheduler implements this method. */ @deprecated("restart will be removed", "2.8.0") def restart() { if (sched.isInstanceOf[ForkJoinScheduler]) { sched.asInstanceOf[ForkJoinScheduler].restart() } else sys.error("scheduler does not implement restart") } } Other Scala examples (source code examples)Here is a short list of links related to this Scala Scheduler.scala source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.