io.pravega.common.concurrent

Class SequentialAsyncProcessor

java.lang.Object

io.pravega.common.concurrent.SequentialAsyncProcessor

All Implemented Interfaces:

java.lang.AutoCloseable

public class SequentialAsyncProcessor
extends java.lang.Object
implements java.lang.AutoCloseable

An Executor extension that runs the same task asynchronously, but never concurrently. If multiple requests are made during an existing execution of the task, it will be invoked exactly once after the current execution completes.

Constructor Summary

Constructors

Constructor and Description
SequentialAsyncProcessor(java.lang.Runnable runnable, Retry.RetryAndThrowBase<? extends java.lang.Throwable> retry, java.util.function.Consumer<java.lang.Throwable> failureCallback, java.util.concurrent.ScheduledExecutorService executor) Region Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
void	runAsync() Executes one instance of the task, or queues it up at most once should the task be currently running.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SequentialAsyncProcessor

public SequentialAsyncProcessor(java.lang.Runnable runnable,
                                Retry.RetryAndThrowBase<? extends java.lang.Throwable> retry,
                                java.util.function.Consumer<java.lang.Throwable> failureCallback,
                                java.util.concurrent.ScheduledExecutorService executor)

Region Constructor.

Parameters:

runnable - The task to run.

retry - A Retry policy to use when executing the runnable.

failureCallback - A Consumer to invoke if the runnable was unable to complete after applying the Retry policy.

executor - An Executor to run the task on.

Method Detail

runAsync

public void runAsync()

Executes one instance of the task, or queues it up at most once should the task be currently running.

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable