`

Kilim源码分析之三 ---- 织入之构造/合并BasicBlock

阅读更多

        上一篇分析了可织入判断的代码,本篇继续分析织入部分的构造/合并BasicBlock。

        首先看下分析方法kilim.analysis.MethodFlow.analyze()包含的功能:

    //织入逻辑 
    public void analyze() throws KilimException {
        buildBasicBlocks();//构造BasicBlock,异常代码怎么构建成块的?
        if (basicBlocks.size() == 0) return;
        consolidateBasicBlocks();//这里会合并一些在逻辑上不需要独立开来的块
        assignCatchHandlers();//把tryCatchBlocks块构造成Handler,然后根据handler的块的起始位置和块的起始位置,给块分配handler,即tryCatch块会catch这个bb的某个类型的异常;tryCatchBlock开始pos会跟代码bb的开始位置重合,会在bb的start和end pos之间么?consolidate合并块导致?
        inlineSubroutines();//这里只是把小于1.5编译级别所产生的jsr指令做了处理;finally块中有pausable则会被拷贝一份;finally块中有pausable则会把jsr/ret指令都替换为goto指令,但是并没有像1.5及以后编译级别那样,拷贝一份代码try/catch代码块编译后的指令块中
        doLiveVarAnalysis();//变量活动性分析
        dataFlow();//数据流分析
        this.labelToBBMap = null; // we don't need this mapping anymore
    }

         来看buildBasicBlock方法及调用的相关方法的实现逻辑:

    //构造BasicBlock
    void buildBasicBlocks() {
        // preparatory phase
        int numInstructions = instructions.size(); 
        basicBlocks = new BBList();//Basic Block 列表
        // Note: i modified within the loop
        for (int i = 0; i < numInstructions; i++) {
            Label l = getOrCreateLabelAtPos(i);//在当前指令位置创建一个Label,这里i并不是连续的,即并非每个位置都会创建一条指令
            BasicBlock bb = getOrCreateBasicBlock(l);//为每个Label创建一个BasicBlock
            i = bb.initialize(i); // i now points to the last instruction in bb.在bb.initialize(i)里,i会增加的 
            basicBlocks.add(bb);//放到bb列表
        }
    }


    Label getOrCreateLabelAtPos(int pos) {
        Label ret = null;
        if (pos < posToLabelMap.size()) {
            ret = posToLabelMap.get(pos);//这是一个List,不是一个Map的
        }
        if (ret == null) {
            ret = new Label();
            setLabel(pos, ret);//为位置pos创建一个Label
        }
        return ret;
    }
    void setLabel(int pos, Label l) {
        //在posToLabelMap后边添加pos - posToLabelMap.size() + 1个null,还是为了做到每条指令都对应一个位置,存储值为null或Label
        for (int i = pos - posToLabelMap.size() + 1; i >= 0; i--) {
            //pad with nulls ala perl
            posToLabelMap.add(null);
        }
        assert posToLabelMap.get(pos) == null;
        posToLabelMap.set(pos, l);//把pos位置上放一个Label
        labelToPosMap.put(l, pos);//Label和位置的映射关系
    }

         下边着重分析下BasicBlock的initialize,分析前先介绍两个概念,BasicBlock是一个指令集合,这些指令集合也叫做一个节点,是必须按照顺序执行的一堆指令,中间不存在跳转。如果按照顺序执行指令,执行当前节点的最后一条指令,与接下来要执行的下一个节点的第一条指令之间是物理相邻的,那么下一个节点就是当前节点的follower。从一个块可以通过跳转或者非跳转指令直接到达的节点,叫做当前节点的后继节点successor,当前节点也叫做后继结点的前驱节点predecessor。

   /**
     * Absorb as many instructions until the next label or the next transfer of
     * control instruction. In the first pass we may end up creating many many
     * BBs because there may be a lot of non-target labels (esp. when debug
     * information is available). The constraints are as follows:   
     * 读取尽量多的指令,直到下一个目标指令或者下一个跳转指令。第一pass,我们创建尽可能多的bbs,因为这里有很多非目标label(比如调试信息)
     *   1. A transfer of control instruction must be the last instruction. It 
     *      may also be the first (and only) instruction. 控制流的跳转指令必须是BasicBlock的最后一条指令
     *   2. A labeled instruction must be the first instruction in a BB. It
     *      may optionally be the last (and only) instruction. 目标指令必须是BasicBlock的第一条指令
     *   3. A pausable method is treated like a labeled instruction, and is 
     *      given a label if there isn't one already. Constraint 2 applies. Pausable方法被当目标指令
     */
    @SuppressWarnings("unchecked")
    int initialize(int pos) {
        AbstractInsnNode ain;
        startPos = pos;
        BasicBlock bb;
        boolean endOfBB = false;
        boolean hasFollower = true;//是否有后继节点
        int size = flow.instructions.size();
        for (; pos < size; pos++) {//从当前位置开始,一条一条指令走起
            if (pos > startPos && flow.getLabelAt(pos) != null) {//如果某条指令已经有对应的Label了
                pos--;//回退一位
                hasFollower = true;//有后继节点
                endOfBB = true;//BasicBlock的末尾
                break;
            }
            ain = getInstruction(pos);//当前位置的指令
            int opcode = ain.getOpcode();//指令操作码
            switch (opcode) {
                case ALOAD:
                case ILOAD:
                case LLOAD:
                case FLOAD:
                case DLOAD:
                    usage.read(((VarInsnNode) ain).var);//load类型指令,把局部变量索引标记为读
                    break;
                case ISTORE:
                case LSTORE:
                case FSTORE:
                case DSTORE:
                case ASTORE:
                    usage.write(((VarInsnNode) ain).var);//store类型指令,把对应局部变量索引标记为写
                    break;
                    
                case IINC:
                    int v = ((IincInsnNode)ain).var;
                    usage.read(v);
                    usage.write(v);//iinc 既读又写
                    break;
                case IFEQ:
                case IFNE:
                case IFLT:
                case IFGE:
                case IFGT:
                case IFLE:
                case IFNULL:
                case IFNONNULL:
                case IF_ICMPEQ:
                case IF_ICMPNE:
                case IF_ICMPLT:
                case IF_ICMPGE:
                case IF_ICMPGT:
                case IF_ICMPLE:
                case IF_ACMPEQ:
                case IF_ACMPNE:
                case JSR:
                case GOTO://if类、jsr、goto类型指令
                    Label l = ((JumpInsnNode) ain).label;//这些指令的目标地址上都创建了label
                    bb = flow.getOrCreateBasicBlock(l);//跳转指令目标地址上创建一个Label
                    if (opcode == JSR) {//jsr指令,标示为IS_SUBROUTINE
                        bb.setFlag(IS_SUBROUTINE);
                        hasFollower = false;//以jsr指令结束的bb没有follower节点
                    }
                    addSuccessor(bb);//给当前BasicBlock添加后继节点,后继节点的前驱节点数也会加1
                    if (opcode == GOTO) {//以goto指令结束的bb没有follower节点
                        hasFollower = false;
                    }
                    endOfBB = true;//bb结束
                    break;
                case RET://finally块的返回指令
                case IRETURN:
                case LRETURN:
                case FRETURN:
                case DRETURN:
                case ARETURN:
                case RETURN:
                case ATHROW://以return、throw类型指令和抛异常指令结束的bb没有follower,没有successor
                    hasFollower = false;
                    endOfBB = true;//bb结束
                    break;
                case TABLESWITCH:
                case LOOKUPSWITCH://switch指令
                    Label defaultLabel;//default跳转的目标位置的label
                    List<Label> otherLabels;//非default跳转的labels
                    if (opcode == TABLESWITCH) {
                        defaultLabel = ((TableSwitchInsnNode) ain).dflt;
                        otherLabels = ((TableSwitchInsnNode) ain).labels;
                    } else {
                        defaultLabel = ((LookupSwitchInsnNode) ain).dflt;
                        otherLabels = ((LookupSwitchInsnNode) ain).labels;
                    }
                    //switch指令的默认和非默认跳转目标地址开始的Label都作为当前bb的后继节点
                    for (Iterator<Label> it = otherLabels.iterator(); it.hasNext();) {
                        l = (Label) it.next();
                        addSuccessor(flow.getOrCreateBasicBlock(l));
                    }
                    addSuccessor(flow.getOrCreateBasicBlock(defaultLabel));
                    endOfBB = true;
                    hasFollower = false;
                    break;
                case INVOKEVIRTUAL:
                case INVOKESTATIC:
                case INVOKEINTERFACE:
                case INVOKESPECIAL://方法调用指令
                    if (flow.isPausableMethodInsn((MethodInsnNode) ain)) {//调用的Pausable的方法
                        if (pos == startPos) {//当前块的第一条指令,那么当前块就是一个pausable块
                            setFlag(PAUSABLE);
                        } else {//否则,当前块结束,为pausable方法指令创建新块和bb
                            l = flow.getOrCreateLabelAtPos(pos);
                            bb = flow.getOrCreateBasicBlock(l);
                            bb.setFlag(PAUSABLE);
                            addSuccessor(bb);//当前bb的后继节点
                            pos--; // don't consume this instruction
                            hasFollower = true;//有follower
                            endOfBB = true;//块结束
                        }
                    }
                    break;
                default:
                if (opcode >= 26 && opcode <= 45)
                    throw new IllegalStateException("instruction variants not expected here");
                
                    break;
            }
            if (endOfBB) break;
        }
        endPos = pos;
        //添加follower,当前bb最后一条指令的下一条指令是follower的第一条指令
        if (hasFollower && (pos + 1) < flow.instructions.size()) {
            // add the following basic block as a successor
            Label l = flow.getOrCreateLabelAtPos(pos + 1);
            bb = flow.getOrCreateBasicBlock(l);
            addFollower(bb);//follower也是一个后继节点的
        }
        return pos;
    }

         整理下以上代码,以jsr、goto、return、throw、switch这些类型指令结束的BasicBlock是没有follower的;以if或者pausable方法的方法调用指令结束的BasicBloc是有follower的,以if、jsr、goto、return、throw、switch、pausable方法的方法调用指令的上一条指令结束的bb是会有后继结点。

    asm框架分析出来的其他Label:(都包括啥?)

   /**
     * In the first pass (buildBasicBlocks()), we create BBs whenever we
     * encounter a label. We don't really know until we are done with that
     * pass whether a label is the target of a branch instruction or it is
     * there because of an exception handler. See coalesceWithFollowingBlock()
     * for more detail.   合并bb
     */
    private void consolidateBasicBlocks() {
        BBList newBBs = new BBList(basicBlocks.size());
        int pos = 0;
        for (BasicBlock bb: basicBlocks) {
            if (!bb.hasFlag(COALESCED)) {
                bb.coalesceTrivialFollowers();//合并
                // The original bb's followers should have been marked as processed.
                bb.setId(pos++);  
                newBBs.add(bb);
            }
        }
        basicBlocks = newBBs;
        assert checkNoBasicBlockLeftBehind();//校验所有bb都正确构造,指令起始位置正确
    }

   
    /**
     * Blocks connected by an edge are candidates for coalescing if: <dl> <li>
     * There is a single edge between the two and neither has any other edges.
     * </li>
     * 
     * <li> The edge connecting the two is not because of a GOTO. We only want
     * those where one block falls into the other. The reason is that each block
     * marks out a *contiguous* range of instructions. Most compilers would have
     * gotten rid of this unnecessary jump anyway. </li>
     * 
     * <li> The successor block doesn't begin with a method call that we are
     * interested in (like pausable methods). This is a boundary we are
     * interested in maintaining in subsequent processing. </li>
     * 什么label隔开的bb可以合并?
     * </dl>
     */
    void coalesceTrivialFollowers() {
        while (true) {
            if (successors.size() == 1) {//当前节点的后继结点只有一个
                BasicBlock succ = successors.get(0);
                if (succ.numPredecessors == 1 && lastInstruction() != GOTO && lastInstruction() != JSR
                        && !succ.isPausable()) {//后继节点的前驱节点也只有一个,当前节点的最后一条指令不是goto/jsr,后继节点第一条指令不是pausable方法调用
                    // successor can be merged
                    // absorb succesors and usage mask
                    this.successors = succ.successors;
                    this.follower = succ.follower;
                    this.usage.absorb(succ.usage);//usage也合并
                    this.endPos = succ.endPos;
                    succ.setFlag(COALESCED);//后继节点是coalesced
                    // mark succ so it doesn't get visited. This block's merk remains 0. We'll let the outer driver
                    // loop to revisit this block and its new successors
                    continue;
                }
            }
            break;
        }
    }
分享到:
评论

相关推荐

    JAVA版本his系统源码-kilim:用于Java的轻量级线程,具有消息传递、nio、http和调度支持

    JAVA版本他的系统源码Kilim :JVM 的延续、纤维、Actor 和消息传递 Kilim 由 2 个主要组件组成: Kilim weaver 修改已编译的 java 类的字节码,启用一种方法来保存它的状态并放弃对其线程的控制,即协同多任务 Kilim...

    actor线程库:kilim0.6

    在kilim-0.6这个压缩包中,包含了kilim库的源码、文档和其他相关资源。使用者可以通过阅读源码了解其内部实现机制,或者直接将其导入到项目中使用。kilim的核心特性包括: 1. **异步消息传递**:每个Actor都有自己...

    协程Coroutine和Kilim

    协程Coroutine和Kilim是两个与并发编程相关的概念,主要在Java开发环境中被讨论。在现代软件系统中,多线程和并发处理是提升性能和响应能力的关键技术。协程提供了一种轻量级的并发模型,它比传统的线程更高效,内存...

    基于角色的消息传递框架Kilim.zip

    Kilim 是一种 Java 消息传递框架,提供了超轻量级的线程,推动了线程之间迅速、安全、无需复制的消息传递的实现。 Kilim 使用 Java 编写,融入了角色模型的概念。在 Kilim 中,“角色” 是使用 Kilim 的 Task 类型...

    vivo X9主板原理图及PCB板图

    通过对该设备的主板原理图及 PCB 板图进行分析,可以更好地理解其内部结构与工作原理,从而在维修过程中提高效率并确保维修质量。 #### 主板原理图解析 1. **主板概述**:vivo X9 的主板主要包含了电源管理、数据...

    kilim-motifs:具有Lindenmayer系统的程序性Kilim主题生成

    《kilim-motifs:基于Lindenmayer系统的程序化Kilim图案生成》 ...同时,"kilim-motifs"也提供了一个实例,说明了开源软件如何促进创新,让全球的开发者都能参与到艺术和技术的融合之中,推动生成艺术的发展。

    基于Kilim、Promise JDeferred、Zookeeper和Spring Boot的协程分布式调用聚合框架设计源码

    该项目是一款基于Kilim、Promise JDeferred、Zookeeper和Spring Boot技术的协程驱动分布式调用聚合框架。源码包含223个文件,涵盖143个Java源文件、33个XML配置文件、13个GIF图片、7个JAR包、5个批处理脚本、4个属性...

    协程式驱动框架Nepxion-Coroutine.zip

    Coroutine是基于Kilim/Promise JDeferred的协程式驱动框架,基于Apache Zookeeper的分布式规则存储和动态规则变更通知。 主要特性: 1. 基于微服务框架理念设计 2. 支持同步/异步调用 3. 支持串行/并行调用 4....

    mapleliang-Jungle Server Core使用与扩展1

    Jungle Server Core采用Maven进行构建,典型的项目源码结构如下: - `svr`:启动类位于`com.tencent.svrcore.demo.Bootstrap`,负责初始化依赖管理容器Guice,加载配置文件`jungle.properties`,定义传输层协议...

    在Java中使用协程.pdf

    总结起来,尽管Java自身尚未在语言层面内置协程支持,但通过使用像Scala和Kilim这样的第三方工具,开发者可以在Java环境中实现类似协程的功能,以提升并发性能。随着技术的发展,未来的Java版本可能会考虑引入对协程...

Global site tag (gtag.js) - Google Analytics