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