Package com.illumon.iris.importers.merge

Class SyncOperator.Concurrent

java.lang.Object

com.illumon.iris.importers.merge.SyncOperator.ExecutorDriven

com.illumon.iris.importers.merge.SyncOperator.Concurrent

All Implemented Interfaces:

SyncOperator

Enclosing interface:

SyncOperator

public static final class SyncOperator.Concurrent
extends SyncOperator.ExecutorDriven

SyncOperator implementation for SyncMode.CONCURRENT.

Nested Class Summary

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

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

Method Summary

Modifier and Type	Method	Description
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 com.illumon.iris.importers.merge.SyncOperator.ExecutorDriven

awaitAll

Methods inherited from class java.lang.Object

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

Method Details

submitSyncTask

public void submitSyncTask(@NotNull
 Runnable syncTask)

Description copied from interface: SyncOperator

Submit a synchronization task for immediate or deferred invocation.

Parameters:

syncTask - The synchronization task

finished

public void finished()

Description copied from interface: SyncOperator

Declare that no further synchronization tasks will be submitted.