摘要：如果有處理耗時(shí)任務(wù)的應(yīng)該怎么辦可以專(zhuān)門(mén)開(kāi)一個(gè)線(xiàn)程池，來(lái)專(zhuān)門(mén)處理耗時(shí)業(yè)務(wù)。如果是在線(xiàn)程，如果想處理耗時(shí)任務(wù)邏輯，那么就需要新建一個(gè)并調(diào)用他的相關(guān)方法其本質(zhì)是一個(gè)用來(lái)處理事件的線(xiàn)程，其本質(zhì)是一個(gè)線(xiàn)程池。

netty 處理耗時(shí)的任務(wù)邏輯，是不能在IO線(xiàn)程處理，因?yàn)檫@會(huì)造成堵塞，將會(huì)嚴(yán)重影響性能。那怎么區(qū)分IO線(xiàn)程呢?
答案就是EventLoop，EventLoop用來(lái)處理IO線(xiàn)程，因此耗時(shí)任務(wù)的handler不要在EventLoop里面處理。
以下面代碼為例：

 bossGroup = new NioEventLoopGroup();
 workerGroup = new NioEventLoopGroup();

 try {
    ServerBootstrap bootstrap = new ServerBootstrap();
    bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
 ....

其中workerGroup就是專(zhuān)門(mén)用來(lái)處理IO線(xiàn)程業(yè)務(wù)邏輯的，例如執(zhí)行一些 編碼、解碼 等不耗時(shí)的業(yè)務(wù)處理。

如果有處理耗時(shí)任務(wù)的handler應(yīng)該怎么辦？
可以專(zhuān)門(mén)開(kāi)一個(gè)線(xiàn)程池，來(lái)專(zhuān)門(mén)處理耗時(shí)業(yè)務(wù)。Netty Api 已經(jīng)提供了一些說(shuō)明，http://netty.io/4.1/api/index...，ChannelPipeline中 可以找到如下描述：

A user is supposed to have one or more ChannelHandlers in a pipeline to receive I/O events (e.g. read) and to request I/O operations (e.g. write and close). For example, a typical server will have the following handlers in each channel"s pipeline, but your mileage may vary depending on the complexity and characteristics of the protocol and business logic:

Protocol Decoder - translates binary data (e.g. ByteBuf) into a Java object.
Protocol Encoder - translates a Java object into binary data.
Business Logic Handler - performs the actual business logic (e.g. database access).
and it could be represented as shown in the following example:
static final EventExecutorGroup group = new DefaultEventExecutorGroup(16);
...

ChannelPipeline pipeline = ch.pipeline();

 pipeline.addLast("decoder", new MyProtocolDecoder());

 pipeline.addLast("encoder", new MyProtocolEncoder());

 // Tell the pipeline to run MyBusinessLogicHandler"s event handler methods
 // in a different thread than an I/O thread so that the I/O thread is not blocked by
 // a time-consuming task.
 // If your business logic is fully asynchronous or finished very quickly, you don"t
 // need to specify a group.
 pipeline.addLast(group, "handler", new MyBusinessLogicHandler());

其中EventExecutorGroup 就是專(zhuān)門(mén)來(lái)處理耗時(shí)業(yè)務(wù)的線(xiàn)程池。

在實(shí)際生產(chǎn)環(huán)境中，我們可能會(huì)碰到 需要臨時(shí)執(zhí)行也行計(jì)劃任務(wù)，，這些任務(wù)如果不耗時(shí)，我們可以通過(guò)channel提供的計(jì)劃任務(wù)方法處理：

future =  channel.eventLoop.scheduleAtFixedRate(new Runnable() {

            @Override
            public void run() {
                            //邏輯代碼，非耗時(shí)任務(wù)
               }
        }, 6, 6, TimeUnit.HOURS);
       ....

如果計(jì)劃任務(wù)里面的邏輯比較耗時(shí)，那么就不能再用eventLoop，因?yàn)檫@會(huì)阻塞IO線(xiàn)程。如果是通過(guò)pipeline.addLast(group, "handler", new MyBusinessLogicHandler()); 這種方式添加的業(yè)務(wù)線(xiàn)程我們可以使用下面的方式添加計(jì)劃任務(wù)方法實(shí)現(xiàn)：

***future = ctx.executor().scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
            }
        }, 6, 6, TimeUnit.HOURS);***

...

netty 源碼

public EventExecutor executor() {
        return (EventExecutor)(this.executor == null？this.channel().eventLoop():this.executor);
    }

如果this.executor為null，就返回channel().eventLoop()，這個(gè)是io讀寫(xiě)線(xiàn)程,肯定是不能執(zhí)行耗時(shí)任務(wù)的。
如果不為空，那么是怎么傳進(jìn)來(lái)的呢?

DefaultChannelPipeline

public final ChannelPipeline addLast(EventExecutorGroup group, String name, ChannelHandler handler) {
        final AbstractChannelHandlerContext newCtx;
        synchronized(this) {
            checkMultiplicity(handler);
            newCtx = this.newContext(group, this.filterName(name, handler), handler);

DefaultChannelPipeline 的addLast(EventExecutorGroup group, String name, ChannelHandler handler)為例，該方法部分源碼如下

    @Override
    public final ChannelPipeline addLast(EventExecutorGroup group, String name, ChannelHandler handler) {
        final AbstractChannelHandlerContext newCtx;
        synchronized (this) {
            checkMultiplicity(handler);

            newCtx = newContext(group, filterName(name, handler), handler);

            addLast0(newCtx);
   ...代碼略去...

private AbstractChannelHandlerContext newContext(EventExecutorGroup group, String name, ChannelHandler handler) {
        return new DefaultChannelHandlerContext(this, this.childExecutor(group), name, handler);
    }

通過(guò)源碼發(fā)現(xiàn)：其實(shí)就是我們?cè)谔砑觝andler時(shí)指定的DefaultEventExecutorGroup。
、所以結(jié)論是：如果在處理耗時(shí)任務(wù)的Handler添加時(shí)用到了DefaultEventExecutorGroup是可以 ctx.executor().scheduleAtFixedRate這么用的，但是如果你再添加handler時(shí)沒(méi)有沒(méi)有指定特殊的EventExecutorGroup，是不能執(zhí)行耗時(shí)任務(wù)的。

如果是在IO線(xiàn)程，如果想處理耗時(shí)任務(wù)邏輯，那么就需要新建一個(gè)EventExecutorGroup,并調(diào)用他的相關(guān)方法

EventLoop:其本質(zhì)是一個(gè)用來(lái)處理IO事件的線(xiàn)程，EventLoopGroup 其本質(zhì)是一個(gè)線(xiàn)程池。一個(gè)EventLoop可以和多個(gè)Channel綁定，處理多個(gè)Channel的IO事件；但是一個(gè)Channel在整個(gè)生命周期內(nèi)只會(huì)被一個(gè)EventLoop處理，這就也就保證了線(xiàn)程安全。