|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
public interface Scheduler
An Akka scheduler service. This one needs one special behavior: if Closeable, it MUST execute all outstanding tasks upon .close() in order to properly shutdown all dispatchers.
Furthermore, this timer service MUST throw IllegalStateException if it cannot schedule a task. Once scheduled, the task MUST be executed. If executed upon close(), the task may execute before its timeout.
Scheduler implementation are loaded reflectively at ActorSystem start-up with the following constructor arguments: 1) the system’s com.typesafe.config.Config (from system.settings.config) 2) a akka.event.LoggingAdapter 3) a java.util.concurrent.ThreadFactory
| Method Summary | |
|---|---|
double |
maxFrequency()
The maximum supported task frequency of this scheduler, i.e. |
Cancellable |
schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
ActorRef receiver,
java.lang.Object message,
scala.concurrent.ExecutionContext executor,
ActorRef sender)
Schedules a message to be sent repeatedly with an initial delay and frequency. |
Cancellable |
schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
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 interval,
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,
ActorRef sender)
Schedules a message to be sent once with a delay, i.e. |
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. |
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. |
| Method Detail |
|---|
Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
ActorRef receiver,
java.lang.Object message,
scala.concurrent.ExecutionContext executor,
ActorRef sender)
Java & Scala API
initialDelay - (undocumented)interval - (undocumented)receiver - (undocumented)message - (undocumented)executor - (undocumented)sender - (undocumented)
Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
scala.Function0<scala.runtime.BoxedUnit> f,
scala.concurrent.ExecutionContext executor)
Scala API
initialDelay - (undocumented)interval - (undocumented)f - (undocumented)executor - (undocumented)
Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
java.lang.Runnable runnable,
scala.concurrent.ExecutionContext executor)
Java API
initialDelay - (undocumented)interval - (undocumented)runnable - (undocumented)executor - (undocumented)
Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
ActorRef receiver,
java.lang.Object message,
scala.concurrent.ExecutionContext executor,
ActorRef sender)
Java & Scala API
delay - (undocumented)receiver - (undocumented)message - (undocumented)executor - (undocumented)sender - (undocumented)
Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
scala.Function0<scala.runtime.BoxedUnit> f,
scala.concurrent.ExecutionContext executor)
Scala API
delay - (undocumented)f - (undocumented)executor - (undocumented)
Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
java.lang.Runnable runnable,
scala.concurrent.ExecutionContext executor)
Java & Scala API
delay - (undocumented)runnable - (undocumented)executor - (undocumented)
double maxFrequency()
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||