pns.alltypes.tasks

Class DelayedTaskQueue

java.lang.Object

pns.alltypes.tasks.DelayedTaskQueue

All Implemented Interfaces:

Serializable

public class DelayedTaskQueue
extends Object
implements Serializable

A task queue with a single thread which allows to do the task with simple wait with timeout. This avoids the heavy threadpool executor and uses a single thread for this.

Author:

arung

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DelayedTaskQueue(int threadCount, String threadName, String executorPoolName, int delay) Instantiates a new delayed task queue.

Method Summary

Methods

Modifier and Type	Method and Description
void	addTask(Runnable r) Adds the task for delayed execution
int	getDelay() Gets the delay.
String	getExecutorPoolName() Gets the executor pool name.
Random	getRANDOM() Gets the random number
protected BlockingDeque<Runnable>	getRESOURCE_RUNNABLES() Gets the resource runnables which needs to be submitted
ExecutorService	getService() Gets the service.
String	getThreadName() Gets the thread name.
void	init() Inits the
void	shutdown() Shutdown the thread

Methods inherited from class java.lang.Object

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

Constructor Detail

DelayedTaskQueue

public DelayedTaskQueue(int threadCount,
                String threadName,
                String executorPoolName,
                int delay)

Instantiates a new delayed task queue.

Parameters:

threadCount - the thread count

threadName - the thread name

executorPoolName - the executor pool name

delay - the delay

Method Detail

init

public void init()

Inits the

addTask

public void addTask(Runnable r)

Adds the task for delayed execution

Parameters:

r - the r

shutdown

public void shutdown()

Shutdown the thread

getRESOURCE_RUNNABLES

protected BlockingDeque<Runnable> getRESOURCE_RUNNABLES()

Gets the resource runnables which needs to be submitted

Returns:

the resource runnables

getDelay

public int getDelay()

Gets the delay.

Returns:

the delay

getExecutorPoolName

public String getExecutorPoolName()

Gets the executor pool name.

Returns:

the executor pool name

getService

public ExecutorService getService()

Gets the service.

Returns:

the service

getThreadName

public String getThreadName()

Gets the thread name.

Returns:

the thread name

getRANDOM

public Random getRANDOM()

Gets the random number

Returns:

the random