Package org.infinispan.xsite.irac

Class IracExecutor

java.lang.Object

org.infinispan.xsite.irac.IracExecutor

All Implemented Interfaces:

Runnable

public class IracExecutor
extends Object
implements 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.

Since:

12

Author:

Pedro Ruivo

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Executor	executor()
void	run()	Executes, in a new thread, or queues the task.
void	setExecutor(Executor executor)

Methods inherited from class java.lang.Object

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

Constructor Details

IracExecutor

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

Method Details

setExecutor

public void setExecutor(Executor executor)

run

public void run()

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

Specified by:

run in interface Runnable

executor

public Executor executor()