Package com.illumon.iris.importers.merge

Class SyncOperator.Immediate

java.lang.Object

com.illumon.iris.importers.merge.SyncOperator.Immediate

All Implemented Interfaces:

SyncOperator

Enclosing interface:

SyncOperator

public static final class SyncOperator.Immediate
extends Object
implements SyncOperator

SyncOperator implementation for SyncMode.IMMEDIATE.

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.importers.merge.SyncOperator

SyncOperator.Concurrent, SyncOperator.ExecutorDriven, SyncOperator.Final, SyncOperator.Immediate

Constructor Summary

Constructors

Constructor	Description
Immediate()

Method Summary

Modifier and Type	Method	Description
boolean	awaitAll(long timeout, TimeUnit timeoutUnit)	Await successful termination of all synchronization tasks.
void	finished()	Declare that no further synchronization tasks will be submitted.
void	submitSyncTask(Runnable syncTask)	Submit a synchronization task for immediate or deferred invocation.

Methods inherited from class java.lang.Object

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

Constructor Details

Immediate

public Immediate()

Method Details

submitSyncTask

public void submitSyncTask(@NotNull
 Runnable syncTask)

Description copied from interface: SyncOperator

Submit a synchronization task for immediate or deferred invocation.

Specified by:

submitSyncTask in interface SyncOperator

Parameters:

syncTask - The synchronization task

finished

public void finished()

Description copied from interface: SyncOperator

Declare that no further synchronization tasks will be submitted.

Specified by:

finished in interface SyncOperator

awaitAll

public boolean awaitAll(long timeout,
 @NotNull
 TimeUnit timeoutUnit)

Description copied from interface: SyncOperator

Await successful termination of all synchronization tasks.

Specified by:

awaitAll in interface SyncOperator

Parameters:

timeout - The timeout

timeoutUnit - Units for the timeout

Returns:

True on success, false if timed out