Package com.linkedin.venice.controller.multitaskscheduler

Class ScheduledTaskManager

java.lang.Object

com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager

Direct Known Subclasses:

StoreMigrationManager

public abstract class ScheduledTaskManager
extends Object

Abstract class for managing scheduled tasks. Other classes can extend this class to implement specific task management logic, and be loaded into MultiTaskSchedulerService to get it running. This class provides a framework for creating and managing a scheduled executor service. It also provides methods for scheduling tasks and shutting down the executor service.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ScheduledExecutorService	executorService

Constructor Summary

Constructors

Constructor	Description
ScheduledTaskManager(int threadPoolSize)

Method Summary

Modifier and Type	Method	Description
protected abstract ScheduledExecutorService	createExecutorService(int threadPoolSize)
protected abstract org.apache.logging.log4j.Logger	getLogger()
ScheduledFuture<?>	scheduleNextStep(Runnable task, int delayInSeconds)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

executorService

protected final ScheduledExecutorService executorService

Constructor Details

ScheduledTaskManager

public ScheduledTaskManager(int threadPoolSize)

Method Details

createExecutorService

protected abstract ScheduledExecutorService createExecutorService(int threadPoolSize)

getLogger

protected abstract org.apache.logging.log4j.Logger getLogger()

shutdown

public void shutdown()

scheduleNextStep

public ScheduledFuture<?> scheduleNextStep(Runnable task,
 int delayInSeconds)