voldemort.common.service
Class SchedulerService

java.lang.Object
  extended by voldemort.common.service.AbstractService
      extended by voldemort.common.service.SchedulerService
All Implemented Interfaces:
VoldemortService

public class SchedulerService
extends AbstractService

The voldemort scheduler


Constructor Summary
SchedulerService(int schedulerThreads, Time time)
           
SchedulerService(int schedulerThreads, Time time, boolean mayInterrupt)
           
 
Method Summary
 void disable(java.lang.String id)
           
 void enable(java.lang.String id)
           
 java.util.List<java.lang.String> getScheduledJobs()
           
 void schedule(java.lang.String id, java.lang.Runnable runnable, java.util.Date timeToRun)
           
 void schedule(java.lang.String id, java.lang.Runnable runnable, java.util.Date nextRun, long periodMs)
           
 void schedule(java.lang.String id, java.lang.Runnable runnable, java.util.Date nextRun, long periodMs, boolean scheduleAtFixedRate)
           
 void scheduleNow(java.lang.Runnable runnable)
           
 void startInner()
           
 void stopInner()
           
 void terminate(java.lang.String id)
           
 
Methods inherited from class voldemort.common.service.AbstractService
getType, isStarted, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SchedulerService

public SchedulerService(int schedulerThreads,
                        Time time)

SchedulerService

public SchedulerService(int schedulerThreads,
                        Time time,
                        boolean mayInterrupt)
Method Detail

startInner

public void startInner()
Specified by:
startInner in class AbstractService

stopInner

public void stopInner()
Specified by:
stopInner in class AbstractService

disable

public void disable(java.lang.String id)

terminate

public void terminate(java.lang.String id)

enable

public void enable(java.lang.String id)

getScheduledJobs

public java.util.List<java.lang.String> getScheduledJobs()

scheduleNow

public void scheduleNow(java.lang.Runnable runnable)

schedule

public void schedule(java.lang.String id,
                     java.lang.Runnable runnable,
                     java.util.Date timeToRun)

schedule

public void schedule(java.lang.String id,
                     java.lang.Runnable runnable,
                     java.util.Date nextRun,
                     long periodMs)

schedule

public void schedule(java.lang.String id,
                     java.lang.Runnable runnable,
                     java.util.Date nextRun,
                     long periodMs,
                     boolean scheduleAtFixedRate)


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu