Timers and reminders
The Orleans runtime provides two mechanisms, called timers and reminders, that enable the developer to specify periodic behavior for grains.
Timers
Timers are used to create periodic grain behavior that isn't required to span multiple activations (instantiations of the grain). A timer is essentially identical to the standard .NET System.Threading.Timer class. In addition, timers are subject to single-threaded execution guarantees within the grain activation that it operates on.
Each activation may have zero or more timers associated with it. The runtime executes each timer routine within the runtime context of the activation that it's associated with.
Timer usage
To start a timer, use the Grain.RegisterTimer method, which returns an IDisposable reference:
public IDisposable RegisterTimer(
Func<object, Task> asyncCallback, // function invoked when the timer ticks
object state, // object to pass to asyncCallback
TimeSpan dueTime, // time to wait before the first timer tick
TimeSpan period) // the period of the timer
To cancel the timer, you dispose of it.
A timer will cease to trigger if the grain is deactivated or when a fault occurs and its silo crashes.
Important considerations:
- When activation collection is enabled, the execution of a timer callback doesn't change the activation's state from idle to in-use. This means that a timer can't be used to postpone the deactivation of otherwise idle activations.
- The period passed to
Grain.RegisterTimer
is the amount of time that passes from the moment the Task returned byasyncCallback
is resolved to the moment that the next invocation ofasyncCallback
should occur. This not only makes it impossible for successive calls toasyncCallback
to overlap, but also makes it so that the length of timeasyncCallback
takes to complete affects the frequency at whichasyncCallback
is invoked. This is an important deviation from the semantics of System.Threading.Timer. - Each invocation of
asyncCallback
is delivered to an activation on a separate turn, and will never run concurrently with other turns on the same activation. However,asyncCallback
invocations aren't delivered as messages and thus aren't subject to message interleaving semantics. This means that invocations ofasyncCallback
will behave as if the grain is re-entrant and will execute concurrently with other grain requests. In order to use the grain's existing scheduling semantics, you can call a grain method to perform the work you would have done withinasyncCallback
. Another alternative is to use anAsyncLock
or a SemaphoreSlim. A more detailed explanation is available in Orleans GitHub issue #2574.
Reminders
Reminders are similar to timers, with a few important differences:
- Reminders are persistent and will continue to trigger in almost all situations (including partial or full cluster restarts) unless explicitly canceled.
- Reminder "definitions" are written to storage. However, each specific occurrence, with its specific time, is not. This has the side effect that if the cluster is down at the time of a specific reminder tick, it will be missed and only the next tick of the reminder will happen.
- Reminders are associated with a grain, not any specific activation.
- If a grain has no activation associated with it when a reminder ticks, the grain will be created. If an activation becomes idle and is deactivated, a reminder associated with the same grain will reactivate the grain when it ticks next.
- Reminders are delivered by message and are subject to the same interleaving semantics as all other grain methods.
- Reminders shouldn't be used for high-frequency timers- their period should be measured in minutes, hours, or days.
Configuration
Reminders, being persistent, rely upon storage to function.
You must specify which storage backing to use before the reminder subsystem will function.
This is done by configuring one of the reminder providers via Use{X}ReminderService
extension methods, where X
is the name of the provider, for example, UseAzureTableReminderService.
Azure Table configuration:
// TODO replace with your connection string
const string connectionString = "YOUR_CONNECTION_STRING_HERE";
var silo = new HostBuilder()
.UseOrleans(builder =>
{
builder.UseAzureTableReminderService(options => options.ConnectionString = connectionString)
})
.Build();
SQL:
const string connectionString = "YOUR_CONNECTION_STRING_HERE";
const string invariant = "YOUR_INVARIANT";
var silo = new HostBuilder()
.UseOrleans(builder =>
{
builder.UseAdoNetReminderService(options =>
{
options.ConnectionString = connectionString;
options.Invariant = invariant;
});
})
.Build();
If you just want a placeholder implementation of reminders to work without needing to set up an Azure account or SQL database, then this will give you a development-only implementation of the reminder system:
var silo = new HostBuilder()
.UseOrleans(builder =>
{
builder.UseInMemoryReminderService();
})
.Build();
Reminder usage
A grain that uses reminders must implement the IRemindable.ReceiveReminder method.
Task IRemindable.ReceiveReminder(string reminderName, TickStatus status)
{
Console.WriteLine("Thanks for reminding me-- I almost forgot!");
return Task.CompletedTask;
}
To start a reminder, use the Grain.RegisterOrUpdateReminder method, which returns an IGrainReminder object:
protected Task<IGrainReminder> RegisterOrUpdateReminder(string reminderName, TimeSpan dueTime, TimeSpan period)
reminderName
: is a string that must uniquely identify the reminder within the scope of the contextual grain.dueTime
: specifies a quantity of time to wait before issuing the first-timer tick.period
: specifies the period of the timer.
Since reminders survive the lifetime of any single activation, they must be explicitly canceled (as opposed to being disposed). You cancel a reminder by calling Grain.UnregisterReminder:
protected Task UnregisterReminder(IGrainReminder reminder)
The reminder
is the handle object returned by Grain.RegisterOrUpdateReminder.
Instances of IGrainReminder
aren't guaranteed to be valid beyond the lifespan of an activation. If you wish to identify a reminder in a way that persists, use a string containing the reminder's name.
If you only have the reminder's name and need the corresponding instance of IGrainReminder
, call the Grain.GetReminder method:
protected Task<IGrainReminder> GetReminder(string reminderName)
Decide which to use
We recommend that you use timers in the following circumstances:
- When it doesn't matter (or is desirable) that the timer ceases to function if the activation is deactivated or failures occur.
- The resolution of the timer is small (for example, reasonably expressible in seconds or minutes).
- The timer callback can be started from Grain.OnActivateAsync() or when a grain method is invoked.
We recommend that you use reminders in the following circumstances:
- When the periodic behavior needs to survive the activation and any failures.
- Performing infrequent tasks (for example, reasonably expressible in minutes, hours, or days).
Combine timers and reminders
You might consider using a combination of reminders and timers to accomplish your goal. For example, if you need a timer with a small resolution that needs to survive across activations, you can use a reminder that runs every five minutes, whose purpose is to wake up a grain that restarts a local timer that may have been lost due to deactivation.
Feedback
Submit and view feedback for