Package org.infinispan.xsite.irac

Class IracExecutor

java.lang.Object

org.infinispan.xsite.irac.IracExecutor

All Implemented Interfaces:

Runnable, Function<Void,CompletionStage<Void>>

public class IracExecutor
extends Object
implements Function<Void,CompletionStage<Void>>, Runnable

Executes the "IRAC" sending task in a single thread.

This executor makes sure no more than one task is running at the same time. Also, it avoids "queueing" multiple tasks by queuing at most one. This is possible because the task does the same thing: iterator over pending updates and send them to the remote site.

In addition, it iteracts with the ExponentialBackOff to add delays in case of network failures.

Since:

12

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
IracExecutor(Supplier<CompletionStage<Void>> runnable)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	apply(Void unused)	Used by CompletableFuture.thenComposeAsync(Function, Executor), it adds the ExponentialBackOff delay.
void	disableBackOff()
void	enableBackOff()
void	run()	Executes, in a new thread, or queues the task.
void	setBackOff(ExponentialBackOff backOff)
void	setExecutor(Executor executor)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Details

IracExecutor

public IracExecutor(Supplier<CompletionStage<Void>> runnable)

Method Details

setExecutor

public void setExecutor(Executor executor)

setBackOff

public void setBackOff(ExponentialBackOff backOff)

run

public void run()

Executes, in a new thread, or queues the task.

Specified by:

run in interface Runnable

enableBackOff

public void enableBackOff()

disableBackOff

public void disableBackOff()

apply

public CompletionStage<Void> apply(Void unused)

Used by CompletableFuture.thenComposeAsync(Function, Executor), it adds the ExponentialBackOff delay.

Specified by:

apply in interface Function<Void,CompletionStage<Void>>

Parameters:

unused - Unused value.

Returns:

The CompletionStage from ExponentialBackOff.asyncBackOff().