Class AtomicCounterEditor.ConsolidatorTask
- java.lang.Object
-
- org.apache.jackrabbit.oak.plugins.atomic.AtomicCounterEditor.ConsolidatorTask
-
- All Implemented Interfaces:
java.util.concurrent.Callable<java.lang.Void>
- Enclosing class:
- AtomicCounterEditor
public static class AtomicCounterEditor.ConsolidatorTask extends java.lang.Object implements java.util.concurrent.Callable<java.lang.Void>
-
-
Field Summary
Fields Modifier and Type Field Description static long
MAX_TIMEOUT
millis over which the task will timeoutstatic long
MIN_TIMEOUT
millis below which the next delay will schedule at this amount.
-
Constructor Summary
Constructors Constructor Description ConsolidatorTask(@NotNull java.lang.String path, @Nullable PropertyState revision, @NotNull NodeStore store, @NotNull java.util.concurrent.ScheduledExecutorService exec, long delay, @NotNull CommitHook hook)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Void
call()
java.lang.String
getName()
static boolean
isTimedOut(long delay)
static long
nextDelay(long currentDelay)
-
-
-
Field Detail
-
MAX_TIMEOUT
public static final long MAX_TIMEOUT
millis over which the task will timeout
-
MIN_TIMEOUT
public static final long MIN_TIMEOUT
millis below which the next delay will schedule at this amount.- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ConsolidatorTask
public ConsolidatorTask(@NotNull @NotNull java.lang.String path, @Nullable @Nullable PropertyState revision, @NotNull @NotNull NodeStore store, @NotNull @NotNull java.util.concurrent.ScheduledExecutorService exec, long delay, @NotNull @NotNull CommitHook hook)
-
-
Method Detail
-
call
public java.lang.Void call() throws java.lang.Exception
- Specified by:
call
in interfacejava.util.concurrent.Callable<java.lang.Void>
- Throws:
java.lang.Exception
-
nextDelay
public static long nextDelay(long currentDelay)
-
isTimedOut
public static boolean isTimedOut(long delay)
-
getName
public java.lang.String getName()
-
-