|  |  |  | 
|---|
|  |  |  | //以下实现,采用了递归调用,当队列缓存结点很多时,会产生栈溢出异常 | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //////////////////////////////////////////////// | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 处理上行数据 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public Integer dealRtuComResult_() { | 
|---|
|  |  |  | Node first = RtuComResultCache.getFirstQueueNode() ; | 
|---|
|  |  |  | if(first != null){ | 
|---|
|  |  |  | Integer count = RtuComResultCache.size() ; | 
|---|
|  |  |  | Node last = RtuComResultCache.getLastQueueNode() ; | 
|---|
|  |  |  | this.doDealRtuComResult_(first, last); | 
|---|
|  |  |  | return count ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return null ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 处理缓存的上行数据节点 | 
|---|
|  |  |  | * @param first 第一个节点 | 
|---|
|  |  |  | * @param last 最后一个节点 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | private void doDealRtuComResult_(Node first, Node last){ | 
|---|
|  |  |  | if(last != null){ | 
|---|
|  |  |  | //在dealNode方法中,可能要把last从队列中移除,这时last.pre为空,所以提前把last.pre取出来 | 
|---|
|  |  |  | Node pre = last.pre ; | 
|---|
|  |  |  | dealNode(last) ; | 
|---|
|  |  |  | if(first != last){ | 
|---|
|  |  |  | doDealRtuComResult_(first, pre) ; | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | //停止 | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //    /** | 
|---|
|  |  |  | //     * 处理上行数据 | 
|---|
|  |  |  | //     */ | 
|---|
|  |  |  | //    public Integer dealRtuComResult_() { | 
|---|
|  |  |  | //        Node first = RtuComResultCache.getFirstQueueNode() ; | 
|---|
|  |  |  | //        if(first != null){ | 
|---|
|  |  |  | //            Integer count = RtuComResultCache.size() ; | 
|---|
|  |  |  | //            Node last = RtuComResultCache.getLastQueueNode() ; | 
|---|
|  |  |  | //            this.doDealRtuComResult_(first, last); | 
|---|
|  |  |  | //            return count ; | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        return null ; | 
|---|
|  |  |  | //    } | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //    /** | 
|---|
|  |  |  | //     * 处理缓存的上行数据节点 | 
|---|
|  |  |  | //     * @param first 第一个节点 | 
|---|
|  |  |  | //     * @param last 最后一个节点 | 
|---|
|  |  |  | //     */ | 
|---|
|  |  |  | //    private void doDealRtuComResult_(Node first, Node last){ | 
|---|
|  |  |  | //        if(last != null){ | 
|---|
|  |  |  | //            //在dealNode方法中,可能要把last从队列中移除,这时last.pre为空,所以提前把last.pre取出来 | 
|---|
|  |  |  | //            Node pre = last.pre ; | 
|---|
|  |  |  | //            dealNode(last) ; | 
|---|
|  |  |  | //            if(first != last){ | 
|---|
|  |  |  | //                doDealRtuComResult_(first, pre) ; | 
|---|
|  |  |  | //            }else{ | 
|---|
|  |  |  | //                //停止 | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //    } | 
|---|
|  |  |  | // | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 处理一个节点 | 
|---|
|  |  |  | * @param node 节点 | 
|---|