public class SystemProcessingTimeService extends ProcessingTimeService
ProcessingTimeService which assigns as current processing time the result of calling
System.currentTimeMillis() and registers timers using a ScheduledThreadPoolExecutor.| Constructor and Description |
|---|
SystemProcessingTimeService(AsyncExceptionHandler failureHandler,
Object checkpointLock) |
SystemProcessingTimeService(AsyncExceptionHandler task,
Object checkpointLock,
ThreadFactory threadFactory) |
| Modifier and Type | Method and Description |
|---|---|
void |
awaitPendingAfterQuiesce()
This method can be used after calling
ProcessingTimeService.quiesce(), and awaits the completion
of currently executing timers. |
protected void |
finalize() |
long |
getCurrentProcessingTime()
Returns the current processing time.
|
boolean |
isTerminated()
Returns true if the service has been shut down, false otherwise.
|
void |
quiesce()
This method puts the service into a state where it does not register new timers, but
returns for each call to
ProcessingTimeService.registerTimer(long, ProcessingTimeCallback) only a "mock" future. |
ScheduledFuture<?> |
registerTimer(long timestamp,
ProcessingTimeCallback target)
Registers a task to be executed no sooner than time
timestamp, but without strong
guarantees of order. |
ScheduledFuture<?> |
scheduleAtFixedRate(ProcessingTimeCallback callback,
long initialDelay,
long period)
Registers a task to be executed repeatedly at a fixed rate.
|
boolean |
shutdownAndAwaitPending(long time,
TimeUnit timeUnit)
Shuts down and clean up the timer service provider hard and immediately.
|
void |
shutdownService()
Shuts down and clean up the timer service provider hard and immediately.
|
boolean |
shutdownServiceUninterruptible(long timeoutMs)
Shuts down and clean up the timer service provider hard and immediately.
|
public SystemProcessingTimeService(AsyncExceptionHandler failureHandler, Object checkpointLock)
public SystemProcessingTimeService(AsyncExceptionHandler task, Object checkpointLock, ThreadFactory threadFactory)
public long getCurrentProcessingTime()
ProcessingTimeServicegetCurrentProcessingTime in class ProcessingTimeServicepublic ScheduledFuture<?> registerTimer(long timestamp, ProcessingTimeCallback target)
timestamp, but without strong
guarantees of order.registerTimer in class ProcessingTimeServicetimestamp - Time when the task is to be enabled (in processing time)target - The task to be executedpublic ScheduledFuture<?> scheduleAtFixedRate(ProcessingTimeCallback callback, long initialDelay, long period)
ProcessingTimeServicescheduleAtFixedRate in class ProcessingTimeServicecallback - to be executed after the initial delay and then after each periodinitialDelay - initial delay to start executing callbackperiod - after the initial delay after which the callback is executedpublic boolean isTerminated()
ProcessingTimeServiceisTerminated in class ProcessingTimeServicepublic void quiesce()
throws InterruptedException
ProcessingTimeServiceProcessingTimeService.registerTimer(long, ProcessingTimeCallback) only a "mock" future.
Furthermore, the method clears all not yet started timers.
This method can be used to cleanly shut down the timer service. The using components will not notice that the service is shut down (as for example via exceptions when registering a new timer), but the service will simply not fire any timer any more.
quiesce in class ProcessingTimeServiceInterruptedExceptionpublic void awaitPendingAfterQuiesce()
throws InterruptedException
ProcessingTimeServiceProcessingTimeService.quiesce(), and awaits the completion
of currently executing timers.awaitPendingAfterQuiesce in class ProcessingTimeServiceInterruptedExceptionpublic void shutdownService()
ProcessingTimeServiceProcessingTimeService.registerTimer(long, ProcessingTimeCallback)
will result in a hard exception.shutdownService in class ProcessingTimeServicepublic boolean shutdownAndAwaitPending(long time,
TimeUnit timeUnit)
throws InterruptedException
ProcessingTimeServiceProcessingTimeService.registerTimer(long, ProcessingTimeCallback) will result in a hard exception after calling this method.shutdownAndAwaitPending in class ProcessingTimeServicetime - time to wait for termination.timeUnit - time unit of parameter time.true if this timer service and all pending timers are terminated and
false if the timeout elapsed before this happened.InterruptedExceptionpublic boolean shutdownServiceUninterruptible(long timeoutMs)
ProcessingTimeServiceProcessingTimeService.registerTimer(long, ProcessingTimeCallback)
will result in a hard exception. This call cannot be interrupted and will block until the shutdown is completed
or the timeout is exceeded.shutdownServiceUninterruptible in class ProcessingTimeServicetimeoutMs - timeout for blocking on the service shutdown in milliseconds.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.