core/org.gnit.lucenekmp.index/MergePolicy/OneMergeProgress

OneMergeProgress

class OneMergeProgress

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.

Constructors

OneMergeProgress

constructor()

Types

enum PauseReason : Enum<MergePolicy.OneMergeProgress.PauseReason>

Reason for pausing the merge thread.

Properties

var isAborted: Boolean

Return the aborted state of this merge.

val pauseTimes: MutableMap<MergePolicy.OneMergeProgress.PauseReason, Long>

Functions

suspend fun abort()

Abort the merge this progress tracks at the next possible moment.

suspend fun pauseNanos(initialPauseNanos: Long, reason: MergePolicy.OneMergeProgress.PauseReason, condition: () -> Boolean)

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.

fun setMergeThread(owner: Job)

suspend fun wakeup()

Request a wakeup for any threads stalled in .pauseNanos.