Progress and state for an executing merge. This class encapsulates the logic to pause and resume the merge thread or to abort the merge entirely.
<init>()Creates a new merge progress info.
abort()Abort the merge this progress tracks at the next possible moment.
isAborted() · also: is_abortedReturn the aborted state of this merge.
pauseNanos(long pauseNanos, org.apache.lucene.index.MergePolicy.OneMergeProgress.PauseReason reason, java.util.function.BooleanSupplier condition)Pauses the calling thread for at least pauseNanos nanoseconds unless the merge
is aborted or the external condition returns false, in which case control
returns immediately.
The external condition is required so that other threads can terminate the pausing
immediately, before pauseNanos expires. We can't rely on just Condition#awaitNanos(long) alone because it can return due to spurious wakeups too.
| name | type | description |
|---|---|---|
| condition | java.util.function.BooleanSupplier | The pause condition that should return false if immediate return from this
method is needed. Other threads can wake up any sleeping thread by calling #wakeup, but it'd fall to sleep for the remainder of the requested time if this
condition |
getPauseTimes() · also: get_pause_timesReturns pause reasons and associated times in nanoseconds.
wakeup()Request a wakeup for any threads stalled in #pauseNanos.