|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.drools.time.impl.JDKTimerService
public class JDKTimerService
A default Scheduler implementation that uses the JDK built-in ScheduledThreadPoolExecutor as the scheduler and the system clock as the clock.
Nested Class Summary | |
---|---|
static class |
JDKTimerService.JDKCallableJob
|
static class |
JDKTimerService.JDKJobHandle
|
Field Summary | |
---|---|
protected ScheduledThreadPoolExecutor |
scheduler
|
Constructor Summary | |
---|---|
JDKTimerService()
|
|
JDKTimerService(int size)
|
Method Summary | |
---|---|
protected Callable<Void> |
createCallableJob(Job job,
JobContext ctx,
Trigger trigger,
JDKTimerService.JDKJobHandle handle,
ScheduledThreadPoolExecutor scheduler)
|
long |
getCurrentTime()
Returns the current time from the scheduler clock |
long |
getTimeToNextJob()
Returns the number of time units (usually ms) to the next scheduled job |
boolean |
removeJob(JobHandle jobHandle)
Remove the job identified by the given job handle from the scheduled queue |
JobHandle |
scheduleJob(Job job,
JobContext ctx,
Trigger trigger)
Schedule a job for later execution |
void |
shutdown()
Shuts the service down |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected ScheduledThreadPoolExecutor scheduler
Constructor Detail |
---|
public JDKTimerService()
public JDKTimerService(int size)
Method Detail |
---|
public long getCurrentTime()
TimerService
getCurrentTime
in interface org.drools.time.SessionClock
getCurrentTime
in interface TimerService
public void shutdown()
TimerService
shutdown
in interface TimerService
public JobHandle scheduleJob(Job job, JobContext ctx, Trigger trigger)
SchedulerService
scheduleJob
in interface SchedulerService
protected Callable<Void> createCallableJob(Job job, JobContext ctx, Trigger trigger, JDKTimerService.JDKJobHandle handle, ScheduledThreadPoolExecutor scheduler)
public boolean removeJob(JobHandle jobHandle)
SchedulerService
removeJob
in interface SchedulerService
jobHandle
- the job identity handle
public long getTimeToNextJob()
TimerService
getTimeToNextJob
in interface TimerService
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |