|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.netty.handler.execution.ExecutionHandler
@ChannelPipelineCoverage(value="all") public class ExecutionHandler
Forwards an upstream ChannelEvent
to an Executor
.
You can implement various thread model by adding this handler to a
ChannelPipeline
. The most common use case of this handler is to
add a ExecutionHandler
which was specified with
OrderedMemoryAwareThreadPoolExecutor
:
ChannelPipeline pipeline = ...; pipeline.addLast("decoder", new MyProtocolDecoder()); pipeline.addLast("encoder", new MyProtocolEncoder()); // HERE pipeline.addLast("executor", newto utilize more processors to handleExecutionHandler
(newOrderedMemoryAwareThreadPoolExecutor
(16, 1048576, 1048576))); pipeline.addLast("handler", new MyBusinessLogicHandler());
ChannelEvent
s. You can also
use other Executor
implementation than the recommended
OrderedMemoryAwareThreadPoolExecutor
.
Constructor Summary | |
---|---|
ExecutionHandler(Executor executor)
Creates a new instance with the specified Executor . |
Method Summary | |
---|---|
Executor |
getExecutor()
Returns the Executor which was specified with the constructor. |
void |
handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event. |
void |
handleUpstream(ChannelHandlerContext context,
ChannelEvent e)
Handles the specified upstream event. |
void |
releaseExternalResources()
Shuts down the Executor which was specified with the constructor
and wait for its termination. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ExecutionHandler(Executor executor)
Executor
.
Specify an OrderedMemoryAwareThreadPoolExecutor
if unsure.
Method Detail |
---|
public Executor getExecutor()
Executor
which was specified with the constructor.
public void releaseExternalResources()
Executor
which was specified with the constructor
and wait for its termination.
releaseExternalResources
in interface ExternalResourceReleasable
public void handleUpstream(ChannelHandlerContext context, ChannelEvent e) throws Exception
ChannelUpstreamHandler
handleUpstream
in interface ChannelUpstreamHandler
context
- the context object for this handlere
- the upstream event to process or intercept
Exception
public void handleDownstream(ChannelHandlerContext ctx, ChannelEvent e) throws Exception
ChannelDownstreamHandler
handleDownstream
in interface ChannelDownstreamHandler
ctx
- the context object for this handlere
- the downstream event to process or intercept
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |