org.apache.ambari.server.topology

Class AsyncCallableService<T>

java.lang.Object

org.apache.ambari.server.topology.AsyncCallableService<T>

Type Parameters:

T - the type returned by the task to be executed

All Implemented Interfaces:

Callable<T>

public class AsyncCallableService<T>
extends Object
implements Callable<T>

Callable service implementation for executing tasks asynchronously. The service repeatedly tries to execute the provided task till it successfully completes, or the provided timeout interval is exceeded.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncCallableService.RetryTaskSilently

Constructor Summary

Constructors

Constructor and Description
AsyncCallableService(Callable<T> task, long timeout, long retryDelay, String taskName, Consumer<Throwable> onError)
AsyncCallableService(Callable<T> task, long timeout, long retryDelay, String taskName, ScheduledExecutorService executorService, Consumer<Throwable> onError)

Method Summary

Modifier and Type	Method and Description
T	call()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncCallableService

public AsyncCallableService(Callable<T> task,
                            long timeout,
                            long retryDelay,
                            String taskName,
                            Consumer<Throwable> onError)

AsyncCallableService

public AsyncCallableService(Callable<T> task,
                            long timeout,
                            long retryDelay,
                            String taskName,
                            ScheduledExecutorService executorService,
                            Consumer<Throwable> onError)

Method Detail

call

public T call()
       throws Exception

Specified by:

call in interface Callable<T>

Throws:

Exception