org.jboss.netty.handler.execution

Class ChainedExecutor

java.lang.Object

org.jboss.netty.handler.execution.ChainedExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, ExternalResourceReleasable

public class ChainedExecutor
extends java.lang.Object
implements java.util.concurrent.Executor, ExternalResourceReleasable

A special Executor which allows to chain a series of Executors and ChannelEventRunnableFilter.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.Executor	cur
private ChannelEventRunnableFilter	filter
private java.util.concurrent.Executor	next

Constructor Summary

Constructors

Constructor and Description
ChainedExecutor(ChannelEventRunnableFilter filter, java.util.concurrent.Executor cur, java.util.concurrent.Executor next) Create a new ChainedExecutor which will used the given ChannelEventRunnableFilter to see if the cur Executor should get used.

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable command) Execute the passed ChannelEventRunnable with the current Executor if the ChannelEventRunnableFilter match.
private static void	releaseExternal(java.util.concurrent.Executor executor)
void	releaseExternalResources() Releases the external resources that this object depends on.

Methods inherited from class java.lang.Object

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

Field Detail

cur

private final java.util.concurrent.Executor cur

next

private final java.util.concurrent.Executor next

filter

private final ChannelEventRunnableFilter filter

Constructor Detail

ChainedExecutor

public ChainedExecutor(ChannelEventRunnableFilter filter,
                       java.util.concurrent.Executor cur,
                       java.util.concurrent.Executor next)

Create a new ChainedExecutor which will used the given ChannelEventRunnableFilter to see if the cur Executor should get used. Otherwise it will pass the work to the next Executor

Parameters:

filter - the ChannelEventRunnableFilter which will be used to check if the ChannelEventRunnable should be passed to the cur or next Executor

cur - the Executor to use if the ChannelEventRunnableFilter match

next - the Executor to use if the ChannelEventRunnableFilter does not match

Method Detail

execute

public void execute(java.lang.Runnable command)

Execute the passed ChannelEventRunnable with the current Executor if the ChannelEventRunnableFilter match. Otherwise pass it to the next Executor in the chain.

Specified by:

execute in interface java.util.concurrent.Executor

releaseExternalResources

public void releaseExternalResources()

Description copied from interface: ExternalResourceReleasable

Releases the external resources that this object depends on. You should not call this method if the external resources (e.g. thread pool) are in use by other objects.

Specified by:

releaseExternalResources in interface ExternalResourceReleasable

releaseExternal

private static void releaseExternal(java.util.concurrent.Executor executor)