alvinalexander.com | career | drupal | java | mac | mysql | perl | scala | uml | unix  

Akka/Scala example source code file (scheduler.rst)

This example Akka source code file (scheduler.rst) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Akka and Scala source code examples by using tags.

All credit for the original source code belongs to akka.io; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Akka tags/keywords

actorsystem, cancellable, if, in, runnable, schedule, scheduler, the, this, you

The scheduler.rst Akka example source code


.. _scheduler-java:

##################
 Scheduler
##################

Sometimes the need for making things happen in the future arises, and where do
you go look then?  Look no further than ``ActorSystem``! There you find the
:meth:`scheduler` method that returns an instance of
:class:`akka.actor.Scheduler`, this instance is unique per ActorSystem and is
used internally for scheduling things to happen at specific points in time.

You can schedule sending of messages to actors and execution of tasks
(functions or Runnable).  You will get a ``Cancellable`` back that you can call
:meth:`cancel` on to cancel the execution of the scheduled operation.

.. warning::

    The default implementation of ``Scheduler`` used by Akka is based on job
    buckets which are emptied according to a fixed schedule.  It does not
    execute tasks at the exact time, but on every tick, it will run everything
    that is (over)due.  The accuracy of the default Scheduler can be modified
    by the ``akka.scheduler.tick-duration`` configuration property.

Some examples
-------------

Schedule to send the "foo"-message to the testActor after 50ms:

.. includecode:: code/docs/actor/SchedulerDocTest.java
   :include: imports1

.. includecode:: code/docs/actor/SchedulerDocTest.java
   :include: schedule-one-off-message

Schedule a Runnable, that sends the current time to the testActor, to be executed after 50ms:

.. includecode:: code/docs/actor/SchedulerDocTest.java
   :include: schedule-one-off-thunk

.. warning::

    If you schedule Runnable instances you should be extra careful
    to not pass or close over unstable references. In practice this means that you should
    not call methods on the enclosing Actor from within the Runnable.
    If you need to schedule an invocation it is better to use the ``schedule()``
    variant accepting a message and an ``ActorRef`` to schedule a message to self
    (containing the necessary parameters) and then call the method when the message is received.

Schedule to send the "Tick"-message to the ``tickActor`` after 0ms repeating every 50ms:

.. includecode:: code/docs/actor/SchedulerDocTest.java
   :include: imports1,imports2

.. includecode:: code/docs/actor/SchedulerDocTest.java
   :include: schedule-recurring

From ``akka.actor.ActorSystem``
-------------------------------

.. includecode:: ../../../akka-actor/src/main/scala/akka/actor/ActorSystem.scala
   :include: scheduler


The Scheduler Interface for Implementors
----------------------------------------

The actual scheduler implementation is loaded reflectively upon
:class:`ActorSystem` start-up, which means that it is possible to provide a
different one using the ``akka.scheduler.implementation`` configuration
property. The referenced class must implement the following interface:

.. includecode:: ../../../akka-actor/src/main/java/akka/actor/AbstractScheduler.java
   :include: scheduler

The Cancellable interface
-------------------------

Scheduling a task will result in a :class:`Cancellable` (or throw an
:class:`IllegalStateException` if attempted after the scheduler’s shutdown).
This allows you to cancel something that has been scheduled for execution.

.. warning::

  This does not abort the execution of the task, if it had already been
  started.  Check the return value of ``cancel`` to detect whether the
  scheduled task was canceled or will (eventually) have run.

.. includecode:: ../../../akka-actor/src/main/scala/akka/actor/Scheduler.scala
   :include: cancellable

Other Akka source code examples

Here is a short list of links related to this Akka scheduler.rst source code file:

... this post is sponsored by my books ...

#1 New Release!

FP Best Seller

 

new blog posts

 

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.