com.appslandia.common.threading

Class TaskScheduler<T>

java.lang.Object

com.appslandia.common.threading.TaskScheduler<T>

public class TaskScheduler<T>
extends Object

Author:

Loc Ha

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskScheduler.Task<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancelMayInterruptIfRunning
protected ScheduledExecutorService	executor
protected AtomicReference<ScheduledFuture<?>>	taskRef

Constructor Summary

Constructors

Constructor and Description
TaskScheduler()
TaskScheduler(boolean cancelMayInterruptIfRunning)
TaskScheduler(boolean cancelMayInterruptIfRunning, ScheduledExecutorService executor)
TaskScheduler(boolean cancelMayInterruptIfRunning, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	hasTask()
void	scheduleAtFixedRate(TaskScheduler.Task<T> task, long initialDelay, long period, TimeUnit unit)
void	scheduleWithFixedDelay(TaskScheduler.Task<T> task, long initialDelay, long delay, TimeUnit unit)
void	shutdownNow()

Methods inherited from class java.lang.Object

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

Field Detail

cancelMayInterruptIfRunning

protected final boolean cancelMayInterruptIfRunning

executor

protected final ScheduledExecutorService executor

taskRef

protected final AtomicReference<ScheduledFuture<?>> taskRef

Constructor Detail

TaskScheduler

public TaskScheduler()

TaskScheduler

public TaskScheduler(boolean cancelMayInterruptIfRunning)

TaskScheduler

public TaskScheduler(boolean cancelMayInterruptIfRunning,
                     ThreadFactory threadFactory)

TaskScheduler

public TaskScheduler(boolean cancelMayInterruptIfRunning,
                     ScheduledExecutorService executor)

Method Detail

scheduleAtFixedRate

public void scheduleAtFixedRate(TaskScheduler.Task<T> task,
                                long initialDelay,
                                long period,
                                TimeUnit unit)

scheduleWithFixedDelay

public void scheduleWithFixedDelay(TaskScheduler.Task<T> task,
                                   long initialDelay,
                                   long delay,
                                   TimeUnit unit)

cancel

public void cancel()

shutdownNow

public void shutdownNow()

hasTask

public boolean hasTask()