|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.DefaultScheduler
public class DefaultScheduler
A scheduler implementation based on a HashedWheelTimer.
The HashedWheelTimer used by this class MUST throw an IllegalStateException if it does not enqueue a task. Once a task is queued, it MUST be executed or returned from stop().
Constructor Summary | |
---|---|
DefaultScheduler(HashedWheelTimer hashedWheelTimer,
LoggingAdapter log)
|
Method Summary | |
---|---|
void |
close()
|
Cancellable |
schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration delay,
ActorRef receiver,
java.lang.Object message,
scala.concurrent.ExecutionContext executor)
Schedules a message to be sent repeatedly with an initial delay and frequency. |
Cancellable |
schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration delay,
scala.Function0<scala.runtime.BoxedUnit> f,
scala.concurrent.ExecutionContext executor)
Schedules a function to be run repeatedly with an initial delay and a frequency. |
Cancellable |
schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration delay,
java.lang.Runnable runnable,
scala.concurrent.ExecutionContext executor)
Schedules a function to be run repeatedly with an initial delay and a frequency. |
Cancellable |
scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
ActorRef receiver,
java.lang.Object message,
scala.concurrent.ExecutionContext executor)
Schedules a message to be sent once with a delay, i.e. a time period that has to pass before the message is sent. |
Cancellable |
scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
scala.Function0<scala.runtime.BoxedUnit> f,
scala.concurrent.ExecutionContext executor)
Schedules a function to be run once with a delay, i.e. a time period that has to pass before the function is run. |
Cancellable |
scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
java.lang.Runnable runnable,
scala.concurrent.ExecutionContext executor)
Schedules a Runnable to be run once with a delay, i.e. a time period that has to pass before the runnable is executed. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DefaultScheduler(HashedWheelTimer hashedWheelTimer, LoggingAdapter log)
Method Detail |
---|
public Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration delay, ActorRef receiver, java.lang.Object message, scala.concurrent.ExecutionContext executor)
Scheduler
Java & Scala API
schedule
in interface Scheduler
public Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration delay, scala.Function0<scala.runtime.BoxedUnit> f, scala.concurrent.ExecutionContext executor)
Scheduler
Scala API
schedule
in interface Scheduler
public Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable runnable, scala.concurrent.ExecutionContext executor)
Scheduler
Java API
schedule
in interface Scheduler
public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable runnable, scala.concurrent.ExecutionContext executor)
Scheduler
Java & Scala API
scheduleOnce
in interface Scheduler
public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay, ActorRef receiver, java.lang.Object message, scala.concurrent.ExecutionContext executor)
Scheduler
Java & Scala API
scheduleOnce
in interface Scheduler
public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay, scala.Function0<scala.runtime.BoxedUnit> f, scala.concurrent.ExecutionContext executor)
Scheduler
Scala API
scheduleOnce
in interface Scheduler
public void close()
close
in interface java.io.Closeable
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |