core/org.gnit.lucenekmp.index/ConcurrentMergeScheduler/MergeThread

MergeThread

open inner class MergeThread(mergeSource: MergeScheduler.MergeSource, val merge: MergePolicy.OneMerge) : Comparable<ConcurrentMergeScheduler.MergeThread>

Runs a merge thread to execute a single merge, then exits.

Constructors

constructor(mergeSource: MergeScheduler.MergeSource, merge: MergePolicy.OneMerge)

Properties

val job: Job

val merge: MergePolicy.OneMerge

val rateLimiter: MergeRateLimiter

Functions

awaitCompletion

suspend fun awaitCompletion()

open operator override fun compareTo(other: ConcurrentMergeScheduler.MergeThread): Int

fun debugPhase(): String

debugPhaseElapsedMs

fun debugPhaseElapsedMs(nowNanos: Long = System.nanoTime()): Long

fun debugThreadId(): Long

fun getName(): String

Mirrors Thread.getName()

fun isAlive(): Boolean

Mirrors Thread.isAlive()

fun start()

Mirrors Thread.start()