The maximum supported task frequency of this scheduler, i.
The maximum supported task frequency of this scheduler, i.e. the inverse of the minimum time interval between executions of a recurring task, in Hz.
Schedules a function to be run repeatedly with an initial delay and a frequency.
Schedules a function to be run repeatedly with an initial delay and a frequency. E.g. if you would like the function to be run after 2 seconds and thereafter every 100ms you would set delay = Duration(2, TimeUnit.SECONDS) and interval = Duration(100, TimeUnit.MILLISECONDS)
Java API
Schedules a Runnable to be run once with a delay, i.
Schedules a Runnable to be run once with a delay, i.e. a time period that has to pass before the runnable is executed.
Java & Scala API
Schedules a function to be run repeatedly with an initial delay and a frequency.
Schedules a function to be run repeatedly with an initial delay and a frequency. E.g. if you would like the function to be run after 2 seconds and thereafter every 100ms you would set delay = Duration(2, TimeUnit.SECONDS) and interval = Duration(100, TimeUnit.MILLISECONDS)
Scala API
Schedules a message to be sent repeatedly with an initial delay and frequency.
Schedules a message to be sent repeatedly with an initial delay and frequency. E.g. if you would like a message to be sent immediately and thereafter every 500ms you would set delay=Duration.Zero and interval=Duration(500, TimeUnit.MILLISECONDS)
Java & Scala API
Schedules a function to be run once with a delay, i.
Schedules a function to be run once with a delay, i.e. a time period that has to pass before the function is run.
Scala API
Schedules a message to be sent once with a delay, i.
Schedules a message to be sent once with a delay, i.e. a time period that has to pass before the message is sent.
Java & Scala API
(scheduler: StringAdd).self
(scheduler: StringFormat).self
(scheduler: ArrowAssoc[Scheduler]).x
(Since version 2.10.0) Use leftOfArrow
instead
(scheduler: Ensuring[Scheduler]).x
(Since version 2.10.0) Use resultOfEnsuring
instead
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