Package eu.rarogsoftware.rarog.platform.core.task

Class DefaultTaskManager

java.lang.Object

eu.rarogsoftware.rarog.platform.core.task.DefaultTaskManager

All Implemented Interfaces:

TaskManager

@Component
@ExportComponent
public class DefaultTaskManager
extends Object
implements TaskManager

Constructor Summary

Constructors

Constructor	Description
DefaultTaskManager(MetricsService metricsService, ApplicationSettings applicationSettings)

Method Summary

Modifier and Type	Method	Description
AdvancedScheduledExecutorService	asExecutorService()	Returns ScheduledExecutorService that provide the same functionality as TaskManager
ThreadFactory	asThreadFactory()	Returns ThreadFactory that provide the same functionality as TaskManager
Thread	createThread(Runnable task)	Start new monitored thread outside of thread pool.
Future<?>	runTask(Runnable task)	Runs provided task as soon as there is free thread in the pool.
<T> Future<T>	runTask(Callable<T> task)	Runs provided task as soon as there is free thread in the pool.
ScheduledFuture<?>	scheduleTask(Runnable task, ScheduleConfig<Void> scheduleConfig)	Runs provided task using provided config
<T> ScheduledFuture<T>	scheduleTask(Callable<T> task, ScheduleConfig<T> scheduleConfig)	Runs provided task using provided config

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultTaskManager

public DefaultTaskManager(MetricsService metricsService,
 ApplicationSettings applicationSettings)

Method Details

createThread

public Thread createThread(Runnable task)

Description copied from interface: TaskManager

Start new monitored thread outside of thread pool. It's equivalent of Thread(Runnable)

Specified by:

createThread in interface TaskManager

Parameters:

task - task to run

Returns:

not started thread with monitoring

runTask

public Future<?> runTask(Runnable task)

Description copied from interface: TaskManager

Runs provided task as soon as there is free thread in the pool.

Specified by:

runTask in interface TaskManager

Parameters:

task - task to run

Returns:

the same Future that would be returned by ExecutorService

runTask

public <T> Future<T> runTask(Callable<T> task)

Description copied from interface: TaskManager

Runs provided task as soon as there is free thread in the pool.

Specified by:

runTask in interface TaskManager

Parameters:

task - task to run

Returns:

the same Future that would be returned by ExecutorService

scheduleTask

public ScheduledFuture<?> scheduleTask(Runnable task,
 ScheduleConfig<Void> scheduleConfig)

Description copied from interface: TaskManager

Runs provided task using provided config

Specified by:

scheduleTask in interface TaskManager

Parameters:

task - task to run

scheduleConfig - config for scheduling task

Returns:

controller for scheduled task

scheduleTask

public <T> ScheduledFuture<T> scheduleTask(Callable<T> task,
 ScheduleConfig<T> scheduleConfig)

Description copied from interface: TaskManager

Runs provided task using provided config

Specified by:

scheduleTask in interface TaskManager

Parameters:

task - task to run

scheduleConfig - config for scheduling task

Returns:

controller for scheduled task

asThreadFactory

public ThreadFactory asThreadFactory()

Description copied from interface: TaskManager

Returns ThreadFactory that provide the same functionality as TaskManager

Specified by:

asThreadFactory in interface TaskManager

Returns:

ThreadFactory

asExecutorService

public AdvancedScheduledExecutorService asExecutorService()

Description copied from interface: TaskManager

Returns ScheduledExecutorService that provide the same functionality as TaskManager

Specified by:

asExecutorService in interface TaskManager

Returns:

ScheduledExecutorService