Package io.fluxcapacitor.common.tracking

Class InMemoryTaskScheduler

java.lang.Object

io.fluxcapacitor.common.tracking.InMemoryTaskScheduler

All Implemented Interfaces:

TaskScheduler

public class InMemoryTaskScheduler
extends Object
implements TaskScheduler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	InMemoryTaskScheduler.Task

Field Summary

Fields

Modifier and Type	Field	Description
static Clock	defaultclock
static int	defaultDelay

Constructor Summary

Constructors

Constructor	Description
InMemoryTaskScheduler()
InMemoryTaskScheduler(int delay)
InMemoryTaskScheduler(int delay, String threadName)
InMemoryTaskScheduler(int delay, String threadName, Clock clock)
InMemoryTaskScheduler(int delay, String threadName, Clock clock, ExecutorService workerPool)
InMemoryTaskScheduler(int delay, Clock clock)
InMemoryTaskScheduler(String threadName)
InMemoryTaskScheduler(String threadName, Clock clock)
InMemoryTaskScheduler(String threadName, Clock clock, ExecutorService workerPool)
InMemoryTaskScheduler(Clock clock)

Method Summary

Modifier and Type	Method	Description
Clock	clock()
void	executeExpiredTasks()
void	executeExpiredTasksAsync()
Registration	schedule(long deadline, ThrowingRunnable task)
void	shutdown()
void	submit(ThrowingRunnable task)
protected void	tryRunTask(InMemoryTaskScheduler.Task task)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.fluxcapacitor.common.tracking.TaskScheduler

orTimeout, schedule, schedule

Field Details

defaultDelay

public static int defaultDelay

defaultclock

public static Clock defaultclock

Constructor Details

InMemoryTaskScheduler

public InMemoryTaskScheduler()

InMemoryTaskScheduler

public InMemoryTaskScheduler(Clock clock)

InMemoryTaskScheduler

public InMemoryTaskScheduler(String threadName)

InMemoryTaskScheduler

public InMemoryTaskScheduler(String threadName,
 Clock clock)

InMemoryTaskScheduler

public InMemoryTaskScheduler(String threadName,
 Clock clock,
 ExecutorService workerPool)

InMemoryTaskScheduler

public InMemoryTaskScheduler(int delay)

InMemoryTaskScheduler

public InMemoryTaskScheduler(int delay,
 Clock clock)

InMemoryTaskScheduler

public InMemoryTaskScheduler(int delay,
 String threadName)

InMemoryTaskScheduler

public InMemoryTaskScheduler(int delay,
 String threadName,
 Clock clock)

InMemoryTaskScheduler

public InMemoryTaskScheduler(int delay,
 String threadName,
 Clock clock,
 ExecutorService workerPool)

Method Details

executeExpiredTasks

public void executeExpiredTasks()

Specified by:

executeExpiredTasks in interface TaskScheduler

executeExpiredTasksAsync

public void executeExpiredTasksAsync()

tryRunTask

protected void tryRunTask(InMemoryTaskScheduler.Task task)

submit

public void submit(ThrowingRunnable task)

Specified by:

submit in interface TaskScheduler

schedule

public Registration schedule(long deadline,
 ThrowingRunnable task)

Specified by:

schedule in interface TaskScheduler

clock

public Clock clock()

Specified by:

clock in interface TaskScheduler

shutdown

public void shutdown()

Specified by:

shutdown in interface TaskScheduler