Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	DelayedExecutor.DelayedRunnable
public class	DelayedExecutor.DelayQueue<E>
public static interface	DelayedExecutor.Resolver<E>
public static interface	DelayedExecutor.Worker<E>

Field Summary

Modifier and Type	Field and Description
private final long	checkIntervalMillis
private volatile boolean	isStarted
private final Queue<DelayedExecutor.DelayQueue<E>>	queues
private final DelayedExecutor.DelayedRunnable	runnable
private final Object	sync
private final ExecutorService	threadPool
public static final long	UNSET_TIMEOUT

Constructor Summary

Access	Constructor and Description
public	DelayedExecutor(final ExecutorService threadPool)
public	DelayedExecutor(final ExecutorService threadPool, final long checkInterval, final TimeUnit timeunit)

Method Summary

Modifier and Type	Method and Description
public <E> DelayedExecutor.DelayQueue<E>	createDelayQueue(final DelayedExecutor.Worker<E> worker, final DelayedExecutor.Resolver<E> resolver)
public void	destroy()
public ExecutorService	getThreadPool()
public void	start()
public void	stop()
private static boolean	wasModified(final long l1, final long l2)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

checkIntervalMillis	back to summary
private final long checkIntervalMillis

isStarted	back to summary
private volatile boolean isStarted

queues	back to summary
private final Queue<DelayedExecutor.DelayQueue<E>> queues

runnable	back to summary
private final DelayedExecutor.DelayedRunnable runnable

sync	back to summary
private final Object sync

threadPool	back to summary
private final ExecutorService threadPool

UNSET_TIMEOUT	back to summary
public static final long UNSET_TIMEOUT

Constructor Detail

DelayedExecutor	back to summary
public DelayedExecutor(final ExecutorService threadPool)

DelayedExecutor	back to summary
public DelayedExecutor(final ExecutorService threadPool, final long checkInterval, final TimeUnit timeunit)

Method Detail

createDelayQueue	back to summary
public <E> DelayedExecutor.DelayQueue<E> createDelayQueue(final DelayedExecutor.Worker<E> worker, final DelayedExecutor.Resolver<E> resolver)

destroy	back to summary
public void destroy()

getThreadPool	back to summary
public ExecutorService getThreadPool() Annotations @SuppressWarnings:UnusedDeclaration

start	back to summary
public void start()

stop	back to summary
public void stop()

wasModified	back to summary
private static boolean wasModified(final long l1, final long l2)

org.glassfish.grizzly.utils back to summary

private Class DelayedExecutor.DelayedRunnable

Class Inheritance

extends Object
implements Runnable

java.lang.Object
org.glassfish.grizzly.utils.DelayedExecutor.DelayedRunnable

All Implemented Interfaces

java.lang.Runnable

Constructor Summary

Access	Constructor and Description
private	DelayedRunnable()

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

DelayedRunnable	back to summary
private DelayedRunnable()

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @SuppressWarnings:unchecked @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@SuppressWarnings:unchecked
@Override

org.glassfish.grizzly.utils back to summary

public Class DelayedExecutor.DelayQueue<E>

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.utils.DelayedExecutor.DelayQueue

Field Summary

Modifier and Type	Field and Description
pack-priv final ConcurrentMap<E, DelayedExecutor.DelayQueue<E>>	queue
pack-priv final DelayedExecutor.Resolver<E>	resolver
pack-priv final DelayedExecutor.Worker<E>	worker

Constructor Summary

Access	Constructor and Description
public	DelayQueue(final DelayedExecutor.Worker<E> worker, final DelayedExecutor.Resolver<E> resolver)

Method Summary

Modifier and Type	Method and Description
public void	add(final E elem, final long delay, final TimeUnit timeUnit)
public void	destroy()
public void	remove(final E elem)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

queue	back to summary
pack-priv final ConcurrentMap<E, DelayedExecutor.DelayQueue<E>> queue

resolver	back to summary
pack-priv final DelayedExecutor.Resolver<E> resolver

worker	back to summary
pack-priv final DelayedExecutor.Worker<E> worker

Constructor Detail

DelayQueue	back to summary
public DelayQueue(final DelayedExecutor.Worker<E> worker, final DelayedExecutor.Resolver<E> resolver)

Method Detail

add	back to summary
public void add(final E elem, final long delay, final TimeUnit timeUnit)

destroy	back to summary
public void destroy()

remove	back to summary
public void remove(final E elem)

org.glassfish.grizzly.utils back to summary

public Interface DelayedExecutor.Resolver<E>

Known Direct Implementers: org.glassfish.grizzly.utils.IdleTimeoutFilter.Resolver, org.glassfish.grizzly.utils.SilentConnectionFilter.Resolver, org.glassfish.grizzly.utils.ActivityCheckFilter.Resolver

Method Summary

Modifier and Type	Method and Description
public long	getTimeoutMillis(E element)
public boolean	removeTimeout(E element)
public void	setTimeoutMillis(E element, long timeoutMillis)

Method Detail

getTimeoutMillis	back to summary
public long getTimeoutMillis(E element)

removeTimeout	back to summary
public boolean removeTimeout(E element)

setTimeoutMillis	back to summary
public void setTimeoutMillis(E element, long timeoutMillis)

org.glassfish.grizzly.utils back to summary

public Interface DelayedExecutor.Worker<E>

Known Direct Implementers: org.glassfish.grizzly.utils.IdleTimeoutFilter.DefaultWorker, org.glassfish.grizzly.utils.ActivityCheckFilter.DefaultWorker

Method Summary

Modifier and Type	Method and Description
public boolean	Returns: `true`, if the work is done and element has to be removed from the delay queue, or `false` if the element should be re-registered on the delay queue again doWork(E element to operate upon. element) The method is executed by `DelayExecutor` once element's timeout expires.

Method Detail

doWork back to summary

doWork	back to summary
public boolean doWork(E element) The method is executed by `DelayExecutor` once element's timeout expires. Parameters element:E element to operate upon. Returns:boolean `true`, if the work is done and element has to be removed from the delay queue, or `false` if the element should be re-registered on the delay queue again

public boolean doWork(E element)

The method is executed by DelayExecutor once element's timeout expires.

Parameters

element:E: element to operate upon.

Returns:boolean

true, if the work is done and element has to be removed from the delay queue, or false if the element should be re-registered on the delay queue again