Mina2.0框架源码剖析(二)

《Mina2.0框架源码剖析(二)》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、上一篇介绍了几个核心的接口，这一篇主要介绍实现这些接口的抽象基类。首先是实现IoService接口的AbstractIoService类。它包含了一个Executor来处理到来的事件。每个AbstractIoService都一个AtomicInteger类型的id号，确保每个id的唯一性。它内部的Executor可以选择是从外部传递进构造函数中，也可以在实例内部自行构造，若是后者，则它将是ThreadPoolExecutor类的一个实例，即是Executor线程池中的一员。代码如下：     if (execut

2、or == null)         {            this.executor = Executors.newCachedThreadPool();            createdExecutor = true;        }         else         {            this.executor = executor;            createdExecutor = false;        }     其中有一个IdleStatusChecker成员

3、，它用来对服务的空闲状态进行检查，在一个服务激活时会将服务纳入到检查名单中，而在服务失效时会将服务从名单中剔除。会单独开一个线程进行具体的空闲检查，这是通过下面这个线程类来负责的：private class NotifyingTaskImpl implements NotifyingTask {        private volatile boolean cancelled;//取消检查标志        private volatile Thread thread;        public void r

4、un(){            thread = Thread.currentThread();            try {                while (!cancelled) {                    //每隔1秒检查一次空闲状态                    long currentTime = System.currentTimeMillis();                    notifyServices(currentTime);         

5、           notifySessions(currentTime);                    try {                        Thread.sleep(1000);                    } catch (InterruptedException e) {                        // will exit the loop if interrupted from interrupt()                    }

6、                }            } Finally {                thread = null;            }        }}具体的空闲检查代码如下，超过能容忍的最大空闲时间，就会fire出SessionIdle事件，上文也说过空闲有三种类型：读端空，写端空，双端空。notifyIdleSession1(s, currentTime,                s.getConfig().getIdleTimeInMillis(IdleStatus.

7、BOTH_IDLE),IdleStatus.BOTH_IDLE,Math.max(s.getLastIoTime(),s.getLastIdleTime(IdleStatus.BOTH_IDLE)));    private static void notifyIdleSession1(            AbstractIoSession session, long currentTime,            long idleTime, IdleStatus status, long lastIoTi

8、me) {        if (idleTime > 0 && lastIoTime != 0                && currentTime - lastIoTime >= idleTime) {            session.getFilterChain().fireSessionIdle(status);        }}     在释放资源