raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Adding overrides on the DefaultScheduler

Browse source
This commit is contained in:
Viktor Klang 2012-05-16 16:28:43 +02:00
parent 07c9bfe6d7
commit 7da74effe6
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
akka-actor/src/main/scala/akka/actor/Scheduler.scala
View file

@ -121,7 +121,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
log: LoggingAdapter, log: LoggingAdapter,
dispatcher: ⇒ MessageDispatcher) extends Scheduler with Closeable { dispatcher: ⇒ MessageDispatcher) extends Scheduler with Closeable {
def schedule(initialDelay: Duration, delay: Duration, receiver: ActorRef, message: Any): Cancellable = { override def schedule(initialDelay: Duration, delay: Duration, receiver: ActorRef, message: Any): Cancellable = {
val continuousCancellable = new ContinuousCancellable val continuousCancellable = new ContinuousCancellable
continuousCancellable.init( continuousCancellable.init(
hashedWheelTimer.newTimeout( hashedWheelTimer.newTimeout(
@ -136,7 +136,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
initialDelay)) initialDelay))
} }
def schedule(initialDelay: Duration, delay: Duration)(f: ⇒ Unit): Cancellable = { override def schedule(initialDelay: Duration, delay: Duration)(f: ⇒ Unit): Cancellable = {
val continuousCancellable = new ContinuousCancellable val continuousCancellable = new ContinuousCancellable
continuousCancellable.init( continuousCancellable.init(
hashedWheelTimer.newTimeout( hashedWheelTimer.newTimeout(
@ -150,7 +150,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
initialDelay)) initialDelay))
} }
def schedule(initialDelay: Duration, delay: Duration, runnable: Runnable): Cancellable = { override def schedule(initialDelay: Duration, delay: Duration, runnable: Runnable): Cancellable = {
val continuousCancellable = new ContinuousCancellable val continuousCancellable = new ContinuousCancellable
continuousCancellable.init( continuousCancellable.init(
hashedWheelTimer.newTimeout( hashedWheelTimer.newTimeout(
@ -163,7 +163,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
initialDelay)) initialDelay))
} }
def scheduleOnce(delay: Duration, runnable: Runnable): Cancellable = override def scheduleOnce(delay: Duration, runnable: Runnable): Cancellable =
new DefaultCancellable( new DefaultCancellable(
hashedWheelTimer.newTimeout( hashedWheelTimer.newTimeout(
new TimerTask() { new TimerTask() {
@ -171,7 +171,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
}, },
delay)) delay))
def scheduleOnce(delay: Duration, receiver: ActorRef, message: Any): Cancellable = override def scheduleOnce(delay: Duration, receiver: ActorRef, message: Any): Cancellable =
new DefaultCancellable( new DefaultCancellable(
hashedWheelTimer.newTimeout( hashedWheelTimer.newTimeout(
new TimerTask { new TimerTask {
@ -179,7 +179,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
}, },
delay)) delay))
def scheduleOnce(delay: Duration)(f: ⇒ Unit): Cancellable = override def scheduleOnce(delay: Duration)(f: ⇒ Unit): Cancellable =
new DefaultCancellable( new DefaultCancellable(
hashedWheelTimer.newTimeout( hashedWheelTimer.newTimeout(
new TimerTask with Runnable { new TimerTask with Runnable {
@ -201,7 +201,7 @@ class DefaultScheduler(hashedWheelTimer: HashedWheelTimer,
} }
} }
def close(): Unit = { override def close(): Unit = {
import scala.collection.JavaConverters._ import scala.collection.JavaConverters._
hashedWheelTimer.stop().asScala foreach execDirectly hashedWheelTimer.stop().asScala foreach execDirectly
} }