NSL Common/xyz.noisif.nsl.common.util.concurrent/VirtualPeriodicTaskScheduler

VirtualPeriodicTaskScheduler

open class VirtualPeriodicTaskScheduler : PeriodicTaskScheduler

Constructors

VirtualPeriodicTaskScheduler

private constructor(ticker: ScheduledExecutorService, virtualWorkers: ExecutorService)

Properties

private val activeTasks: Map<String, ScheduledFuture<out Any>>

private val LOG: Logger

private val ticker: ScheduledExecutorService

private val virtualWorkers: ExecutorService

Functions

open fun cancel(taskId: String)

open fun cancelAll()

open fun create(ticker: ScheduledExecutorService, virtualWorkers: ExecutorService): PeriodicTaskScheduler

scheduleAtFixedRate

open fun scheduleAtFixedRate(taskId: String, task: Runnable, initialDelay: Long, period: Long, unit: TimeUnit)