Package dev.getelements.elements.rt

Class SimpleScheduler

java.lang.Object

dev.getelements.elements.rt.SimpleScheduler

All Implemented Interfaces:

Scheduler

public class SimpleScheduler
extends Object
implements Scheduler

The simple handler server is responsible for dispatching requests and events to all Resource instances contained therein. Internally, it leverages an instance an ExecutorService and a CompletionService to perform all updates in parallel. Created by patricktwohig on 8/22/15.

Constructor Summary

Constructors

Constructor	Description
SimpleScheduler()

Method Summary

Modifier and Type	Method	Description
ExecutorServiceFactory<ExecutorService>	getExecutorServiceFactory()
ResourceService	getResourceService()
ExecutorServiceFactory<ScheduledExecutorService>	getScheduledExecutorServiceFactory()
<T> Future<T>	perform(ResourceId resourceId, Function<ResourceService.ResourceTransaction,T> operation, Consumer<Throwable> failure)	Performs an action against the resource with the provided ResourceId.
<T> Future<T>	perform(Path path, Function<ResourceService.ResourceTransaction,T> operation, Consumer<Throwable> failure)	Performs an action against the resource with the provided ResourceId
<T> Future<T>	performAfterDelay(ResourceId resourceId, long time, TimeUnit timeUnit, Function<ResourceService.ResourceTransaction,T> operation, Consumer<Throwable> failure)	Performs the supplied Function<Resource,T> after a specified delay.
Future<Void>	scheduleDestruction(ResourceId resourceId)
RunnableFuture<Void>	scheduleDestruction(ResourceId resourceId, long delay, TimeUnit timeUnit)	Provided the ResourceId, this will schedule destruction at some point in the near future, but not before.
RunnableFuture<Void>	scheduleUnlink(Path path, long delay, TimeUnit timeUnit)	Provided the Path, this will schedule an unlink operation at some point in the near future, but not before the delay time specified in the parameters of this method.
void	setExecutorServiceFactory(ExecutorServiceFactory<ExecutorService> executorServiceFactory)
void	setResourceService(ResourceService resourceService)
void	setScheduledExecutorServiceFactory(ExecutorServiceFactory<ScheduledExecutorService> scheduledExecutorServiceFactory)
void	start()	Starts the Scheduler.
void	stop()	Shuts down the Scheduler.
<T> Future<T>	submit(Callable<T> tCallable)	Submits an arbitrary Callable<T> to run within the Scheduler.

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.getelements.elements.rt.Scheduler

performAfterDelayV, performV, performV, resumeTask, resumeTaskAfterDelay, submitV

Constructor Details

SimpleScheduler

public SimpleScheduler()

Method Details

start

public void start()

Description copied from interface: Scheduler

Starts the Scheduler. Attempting to invoke any the other methods before invoking this will result in an IllegalStateException.

Specified by:

start in interface Scheduler

stop

public void stop()

Description copied from interface: Scheduler

Shuts down the Scheduler. Attempting to invoke any the other methods after invoking this will result in an IllegalStateException until a subsequent call to Scheduler.start() is made.

Specified by:

stop in interface Scheduler

submit

public <T> Future<T> submit(Callable<T> tCallable)

Description copied from interface: Scheduler

Submits an arbitrary Callable<T> to run within the Scheduler.

Specified by:

submit in interface Scheduler

Parameters:

tCallable - the Callable<T> to run

Returns:

a Future<T> to control the execution state of the task

scheduleUnlink

public RunnableFuture<Void> scheduleUnlink(Path path,
 long delay,
 TimeUnit timeUnit)

Description copied from interface: Scheduler

Provided the Path, this will schedule an unlink operation at some point in the near future, but not before the delay time specified in the parameters of this method. Any pending operations to relase their locks gracefully unlink an potentially destroy any Resources associated with the supplied Path. If the Resource is removed this will ensure that the Resource.close() method is called appropriately. This returns a RunnableFuture<Void> which may be run sooner to short-circuit the unlink operation

Specified by:

scheduleUnlink in interface Scheduler

Parameters:

path - the Path to unlink

Returns:

a RunnableFuture<Void> used to signal destruction, may be run sooner by the calling code

scheduleDestruction

public RunnableFuture<Void> scheduleDestruction(ResourceId resourceId,
 long delay,
 TimeUnit timeUnit)

Description copied from interface: Scheduler

Provided the ResourceId, this will schedule destruction at some point in the near future, but not before. the delay specified in the arguments to this method. This allows any pending operations to scheduleRelease their locks gracefully and destroy the Resource associated with the supplied. ResourceId. This ensures that the underlying Resource is removed from the ResourceService and its Resource.close() method invoked. This returns a RunnableFuture<Void> which may be run sooner to short-circuit the unlink operation

Specified by:

scheduleDestruction in interface Scheduler

Parameters:

resourceId - the ResourceId

Returns:

a RunnableFuture<Void> used to signal destruction, may be run sooner by the calling code

scheduleDestruction

public Future<Void> scheduleDestruction(ResourceId resourceId)

perform

public <T> Future<T> perform(ResourceId resourceId,
 Function<ResourceService.ResourceTransaction,T> operation,
 Consumer<Throwable> failure)

Description copied from interface: Scheduler

Performs an action against the resource with the provided ResourceId.

Specified by:

perform in interface Scheduler

Parameters:

resourceId - the id of the resource

operation - the operation to perform

Returns:

Future<T> which can be used to monitor the status of the request

perform

public <T> Future<T> perform(Path path,
 Function<ResourceService.ResourceTransaction,T> operation,
 Consumer<Throwable> failure)

Description copied from interface: Scheduler

Performs an action against the resource with the provided ResourceId

Specified by:

perform in interface Scheduler

Type Parameters:

T -

Parameters:

path - the path of the resource

operation - the operation to perform

Returns:

Future<T> which can be used to monitor the status of the request

performAfterDelay

public <T> Future<T> performAfterDelay(ResourceId resourceId,
 long time,
 TimeUnit timeUnit,
 Function<ResourceService.ResourceTransaction,T> operation,
 Consumer<Throwable> failure)

Description copied from interface: Scheduler

Performs the supplied Function<Resource,T> after a specified delay. The delay is calculated using the supplied time and TimeUnit.

Specified by:

performAfterDelay in interface Scheduler

Type Parameters:

T -

Parameters:

resourceId - the id of the resource

time - the time value to delay

timeUnit - the units of the time value

operation - the operation to perform

Returns:

Future<T> which can be used to monitor the status of the request

getExecutorServiceFactory

public ExecutorServiceFactory<ExecutorService> getExecutorServiceFactory()

setExecutorServiceFactory

@Inject
public void setExecutorServiceFactory(@Named("dev.getelements.elements.rt.executor")
 ExecutorServiceFactory<ExecutorService> executorServiceFactory)

getScheduledExecutorServiceFactory

public ExecutorServiceFactory<ScheduledExecutorService> getScheduledExecutorServiceFactory()

setScheduledExecutorServiceFactory

@Inject
public void setScheduledExecutorServiceFactory(@Named("dev.getelements.elements.rt.scheduled.executor")
 ExecutorServiceFactory<ScheduledExecutorService> scheduledExecutorServiceFactory)

getResourceService

public ResourceService getResourceService()

setResourceService

@Inject
public void setResourceService(ResourceService resourceService)