public interface ProcessingTimeService
The access to the time via
getCurrentProcessingTime() is always available, regardless of
whether the timer service has been shut down.
|Modifier and Type||Method and Description|
Returns the current processing time.
Registers a task to be executed when (processing) time is
Registers a task to be executed repeatedly at a fixed rate.
ScheduledFuture<?> registerTimer(long timestamp, ProcessingTimeCallback target)
timestamp- Time when the task is to be executed (in processing time)
target- The task to be executed
ScheduledFuture<?> scheduleAtFixedRate(ProcessingTimeCallback callback, long initialDelay, long period)
callback- to be executed after the initial delay and then after each period
initialDelay- initial delay to start executing callback
period- after the initial delay after which the callback is executed
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.