Class AsyncExecutionImpl<R>

java.lang.Object

dev.failsafe.ExecutionImpl<R>

dev.failsafe.AsyncExecutionImpl<R>

Type Parameters:

R - result type

All Implemented Interfaces:

AsyncExecution<R>, ExecutionContext<R>, AsyncExecutionInternal<R>, ExecutionInternal<R>

final class AsyncExecutionImpl<R>
extends ExecutionImpl<R>
implements AsyncExecutionInternal<R>

AsyncExecution and AsyncExecutionInternal implementation.

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	asyncExecution
private final FailsafeFuture<R>	future
private Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>>	outerFn
private final boolean[]	policyPostExecuted
private boolean	recorded

Fields inherited from class ExecutionImpl

attemptRecorded, cancelCallback, cancelledIndex, completed, policyExecutors, result

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AsyncExecutionImpl(AsyncExecutionImpl<R> execution)	Create an async execution for a new attempt.
(package private)	AsyncExecutionImpl(List<Policy<R>> policies, Scheduler scheduler, FailsafeFuture<R> future, boolean asyncExecution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn)

Method Summary

Modifier and Type	Method	Description
void	complete()	Completes the execution and the associated CompletableFuture.
private void	complete(ExecutionResult<R> result, Throwable error)
AsyncExecutionInternal<R>	copy()	Returns a new copy of the AsyncExecutionInternal.
(package private) void	executeAsync()	Performs an asynchronous execution.
boolean	isAsyncExecution()	Returns whether the execution is an async integration execution.
boolean	isComplete()	Returns whether the execution is complete or if it can be retried.
boolean	isPostExecuted(int policyIndex)	Returns whether the PolicyExecutor corresponding to the policyIndex has already post-executed.
boolean	isRecorded()	Returns whether one of the public AsyncExecution record or complete methods have been called.
void	record(R result, Throwable exception)	Records an execution result or exception which triggers failure handling, if needed, by the configured policies.
void	recordException(Throwable exception)	Records an exception which triggers failure handling, if needed, by the configured policies.
void	recordResult(R result)	Records an execution result which triggers failure handling, if needed, by the configured policies.
void	setPostExecuted(int policyIndex)	Sets the PolicyExecutor corresponding to the policyIndex as having post-executed.

Methods inherited from class ExecutionImpl

cancel, cancel, getAttemptCount, getElapsedAttemptTime, getElapsedTime, getExecutionCount, getLastException, getLastResult, getLastResult, getLatest, getLock, getResult, getStartTime, isCancelled, isCancelled, isFirstAttempt, isPreExecuted, isRetry, onCancel, postExecute, preExecute, record, recordAttempt, toString

Methods inherited from class Object

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

Methods inherited from interface ExecutionContext

getAttemptCount, getElapsedAttemptTime, getElapsedTime, getExecutionCount, getLastException, getLastResult, getLastResult, getStartTime, isCancelled, isFirstAttempt, isRetry, onCancel

Methods inherited from interface ExecutionInternal

cancel, cancel, getLatest, getLock, getResult, isCancelled, isPreExecuted, preExecute, record, recordAttempt

Field Details

future

private final FailsafeFuture<R> future

asyncExecution

private final boolean asyncExecution

outerFn

private Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> outerFn

policyPostExecuted

private final boolean[] policyPostExecuted

recorded

private volatile boolean recorded

Constructor Details

AsyncExecutionImpl

AsyncExecutionImpl(List<Policy<R>> policies,
 Scheduler scheduler,
 FailsafeFuture<R> future,
 boolean asyncExecution,
 Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn)

AsyncExecutionImpl

private AsyncExecutionImpl(AsyncExecutionImpl<R> execution)

Create an async execution for a new attempt.

Method Details

complete

public void complete()

Description copied from interface: AsyncExecution

Completes the execution and the associated CompletableFuture.

Specified by:

complete in interface AsyncExecution<R>

isComplete

public boolean isComplete()

Description copied from interface: AsyncExecution

Returns whether the execution is complete or if it can be retried. An execution is considered complete only when all configured policies consider the execution complete.

Specified by:

isComplete in interface AsyncExecution<R>

record

public void record(R result,
 Throwable exception)

Description copied from interface: AsyncExecution

Records an execution result or exception which triggers failure handling, if needed, by the configured policies. If policy handling is not possible or already complete, the resulting CompletableFuture is completed.

Specified by:

record in interface AsyncExecution<R>

recordResult

public void recordResult(R result)

Description copied from interface: AsyncExecution

Records an execution result which triggers failure handling, if needed, by the configured policies. If policy handling is not possible or already complete, the resulting CompletableFuture is completed.

Specified by:

recordResult in interface AsyncExecution<R>

recordException

public void recordException(Throwable exception)

Description copied from interface: AsyncExecution

Records an exception which triggers failure handling, if needed, by the configured policies. If policy handling is not possible or already complete, the resulting CompletableFuture is completed.

Specified by:

recordException in interface AsyncExecution<R>

isAsyncExecution

public boolean isAsyncExecution()

Description copied from interface: AsyncExecutionInternal

Returns whether the execution is an async integration execution.

Specified by:

isAsyncExecution in interface AsyncExecutionInternal<R>

isRecorded

public boolean isRecorded()

Description copied from interface: AsyncExecutionInternal

Returns whether one of the public AsyncExecution record or complete methods have been called.

Specified by:

isRecorded in interface AsyncExecutionInternal<R>

setPostExecuted

public void setPostExecuted(int policyIndex)

Description copied from interface: AsyncExecutionInternal

Sets the PolicyExecutor corresponding to the policyIndex as having post-executed.

Specified by:

setPostExecuted in interface AsyncExecutionInternal<R>

isPostExecuted

public boolean isPostExecuted(int policyIndex)

Description copied from interface: AsyncExecutionInternal

Returns whether the PolicyExecutor corresponding to the policyIndex has already post-executed.

Specified by:

isPostExecuted in interface AsyncExecutionInternal<R>

copy

public AsyncExecutionInternal<R> copy()

Description copied from interface: AsyncExecutionInternal

Returns a new copy of the AsyncExecutionInternal.

Specified by:

copy in interface AsyncExecutionInternal<R>

executeAsync

void executeAsync()

Performs an asynchronous execution.

complete

private void complete(ExecutionResult<R> result,
 Throwable error)