CloudSim源码分析之startSimulation()

1050阅读　0评论2014-03-21　xiaoyao3857
分类：云计算

                                                                 CloudSim源码分析之startSimulation()

在CloudSim源码中的example都是通过startSimulation()启动仿真过程，实际上startSimulation()方法内部做了非常多的工作，此次博客将详细分析startSimulation()方法的工作流程。

startSimulation()是CloudSim类的静态方法，该方法在所有的实体被创建和加载之后调用，开始执行CloudSim仿真，直到所有的实体完全执行（所有的实体线程到达non-RUNNABLE状态或者在future队列中没有事件）才结束。

startSimulation()方法完成的核心工作：

1、启动所有在startSimulation()方法之前定义好的实体（CloudSimShutdown、CloudInformationService、Datacenter、DatacenterBroker）。核心是根据不同实体间的逻辑关系创建相关事件，并将事件添加到等待队列（future）。比如：datacenter实体首先需要向CIS注册，因此datacenter会创建一个向CIS请求注册的事件，并将该事件添加到等待队列；datacenterBroker实体需要知道数据中心特征，因此datacenterBroker会创建一个向datacenter实体请求数据中心特征的事件，并将该事件添加到等待队列。在下面的源码中会按照方法调用的深度详细分析。
    （1）startSimulation()源码分析：    

点击(此处)折叠或打开

  1. // CloudSim类的静态方法，该方法在所有的实体被创建和加载之后调用，开始执行CloudSim仿真，直到所有的实体完全执行

  3.     // （所有的实体线程到达non-RUNNABLE状态或者在future队列中没有事件）才结束。

  5.     public static double startSimulation() throws NullPointerException {
  6.         Log.printLine("Starting CloudSim version " + CLOUDSIM_VERSION_STRING);
  7.         try {
  8.             // 开始仿真至结束

  10.             double clock = run();

  12.             // reset all static variables

  14.             // 仿真结束，重设所有的静态变量

  16.             cisId = -1;
  17.             shutdownId = -1;
  18.             cis = null;
  19.             calendar = null;
  20.             traceFlag = false;

  22.             return clock;
  23.         } catch (IllegalArgumentException e) {
  24.             e.printStackTrace();
  25.             throw new NullPointerException("CloudSim.startCloudSimulation() :"
  26.                     + " Error - you haven't initialized CloudSim.");
  27.         }
  28.     }
   （2）run()开始仿真：

点击(此处)折叠或打开

  1. // 开始仿真直到结束仿真

  3.     public static double run() {
  4.         if (!running) {
  5.             runStart(); // 开始仿真，start所有实体    
  6.         }
  7.     .......
  8.     }
   （3）runStart()启动所有仿真实体：

点击(此处)折叠或打开

  1. // 启动仿真实体

  3.     public static void runStart() {
  4.         running = true;
  5.         // Start all the entities

  7.         for (SimEntity ent : entities) {
  8.             Log.printLine("实体名称:"+ent.getName());
  9.             // 每个实体都继承了SimEntity类的startEntity（）方法，实际工作是向其他实体发送一个请求事件，

  11.             // 并将该事件添加到future队列中。

  13.             ent.startEntity();
  14.         }

  16.         printMessage("Entities started.");
  17.     }
   （4）启动云实体datacenterBroker

点击(此处)折叠或打开

  1. // 启动云实体
  2.     @Override
  3.     public void startEntity() {
  4.         Log.printLine(getName() + " is starting...");
  5.         // 通过id和数据向另一个实体发送事件，请求数据中心特征
  6.         schedule(getId(), 0, CloudSimTags.RESOURCE_CHARACTERISTICS_REQUEST);
  7.     }
   （5）向另外实体发送事件

点击(此处)折叠或打开

  1. // 向另外一个实体发送关联事件

  3.     public void schedule(int dest, double delay, int tag, Object data) {
  4.         if (!CloudSim.running()) {
  5.             return;
  6.         }
  7.         CloudSim.send(id, dest, delay, tag, data);
  8.     }
   （6）创建仿真事件，并添加到等待队列

点击(此处)折叠或打开

  1. // 一个实体向另一个实体发送事件

  3.     public static void send(int src, int dest, double delay, int tag, Object data) {
  4.         // 事件发生的延时不能为负值

  6.         if (delay < 0) {
  7.             throw new IllegalArgumentException("Send delay can't be negative.");
  8.         }

  10.         // 创建一个仿真事件对象

  12.         SimEvent e = new SimEvent(SimEvent.SEND, clock + delay, src, dest, tag, data);
  13.         Log.printLine("````````````````````"+e.getTag());
  14.         // 将创建的事件添加到等待队列中

  16.         future.addEvent(e);
  17.     }


2、处理具体的仿真任务，实际是处理延时队列以及等待队列中的各种事件。CloudSim允许仿真突然中止、在特定时刻中止仿真、在某一时刻暂停仿真，最主要也最一般的情况是在一个时钟心跳期间处理事件队列中的事件。在下面的源码中会按照方法调用的深度详细分析。
    （1）处理仿真事件

点击(此处)折叠或打开

  1. // 开始仿真直到结束仿真

  3.     public static double run() {
  4.         if (!running) {
  5.             runStart(); // 开始仿真，start所有实体
  6.         }
  7.         while (true) {
  8.             // 运行一个时钟心跳如果future中没有事件了，则runClockTick（）返回true，或者突然中断，while循环终止，仿真结束。
  9.             if (runClockTick() || abruptTerminate) {
  10.                 break;
  11.             }

  13.             // this block allows termination of simulation at a specific time
  14.             // 允许在特定的时间点终止仿真。
  15.             if (terminateAt > 0.0 && clock >= terminateAt) {
  16.                 terminateSimulation(); // 终止仿真

  18.                 clock = terminateAt;
  19.                 break;
  20.             }
  21.             // 在某一时刻（pauseAt）暂停仿真
  22.             if (pauseAt != -1
  23.                     && ((future.size() > 0 && clock <= pauseAt && pauseAt <= future.iterator().next()
  24.                             .eventTime()) || future.size() == 0 && pauseAt <= clock)) {
  25.                 pauseSimulation(); // 设置paused为true

  27.                 clock = pauseAt;
  28.             }

  30.             // 如果paused为true，则线程休眠100毫秒，但是何时会重新设置paused为false，终止暂定仿真呢？
  31.             while (paused) {
  32.                 try {
  33.                     Thread.sleep(100);
  34.                 } catch (InterruptedException e) {
  35.                     e.printStackTrace();
  36.                 }
  37.             }
  38.         }
  39.         ........
  40.     }
   （2）处理延时队列和等待队列中的事件，分析runClockTick()方法

点击(此处)折叠或打开

  1.     // 运行一个时钟滴答，首先处理延时队列（deferred）中跟各个实体相关的事件。当延时队列为空时，
  2.     // 处理等待队列（future）中的事件，问题是deferred中的事件是何时从future中添加过来的？
  3.     public static boolean runClockTick() {
  4.         SimEntity ent;
  5.         boolean queue_empty;
  6.         int entities_size = entities.size(); // 实体的个数

  8.         for (int i = 0; i < entities_size; i++) { // 逐个获取实体

  10.             ent = entities.get(i);
  11.             if (ent.getState() == SimEntity.RUNNABLE) { // 设置实体状态为RUNNABLE
  13.                 // run()是各实体类继承了SimEntity类的方法，作用是处理与各个实体相关的事件。
  14.                 ent.run();
  15.             }
  16.         }

  18.         // If there are more future events then deal with them
  19.         // 等待队列中还有未处理的事件
  20.         if (future.size() > 0) {
  21.             List<SimEvent> toRemove = new ArrayList<SimEvent>();
  22.             Iterator<SimEvent> it = future.iterator();
  23.             queue_empty = false;
  24.             SimEvent first = it.next();
  25.             processEvent(first);// 直接处理了！事件何时添加到future队列中呢？

  27.             future.remove(first);

  29.             it = future.iterator();

  31.             // Check if next events are at same time...
  32.             boolean trymore = it.hasNext();
  33.             while (trymore) {
  34.                 SimEvent next = it.next();
  35.                 // 检查下一个事件的时间是否相同，相同则处理下一个事件，因为必须在同一个时钟心跳。
  36.                 if (next.eventTime() == first.eventTime()) {
  37.                     processEvent(next);
  38.                     toRemove.add(next);
  39.                     trymore = it.hasNext();
  40.                 } else {
  41.                     trymore = false;
  42.                 }
  43.             }

  45.             future.removeAll(toRemove);

  47.         } else {
  48.             queue_empty = true;
  49.             running = false;
  50.             printMessage("Simulation: No more future events");
  51.         }

  53.         return queue_empty;
  54.     }
    （3）分析SimEntity类的run()方法

点击(此处)折叠或打开

  1.     //所有的实体都直接继承了run()方法，并没有重写。
  2.     public void run() {

  4.         // evbuf如果为null，则ev=getNextEvent(),否则ev=evbuf.
  5.         // getNextEvent():获取延时队列（deferred）中第一个事件（可算找到你了）
  6.         SimEvent ev = evbuf != null ? evbuf : getNextEvent();
  7.         
  8.         while (ev != null) {

  10.             // 每个实体类都有自己的processEvent（）方法，哪个实体调用了run（）方法，就会调用其processEvent（）方法。
  11.             processEvent(ev);
  12.             if (state != RUNNABLE) {
  13.                 break;
  14.             }

  16.             ev = getNextEvent();
  17.         }

  19.         evbuf = null;
  20.     }
    （4）每个实体类都重载了processEvent()方法，负责处理与自己相关的事件

点击(此处)折叠或打开

  1. // DatacenterBroker重载的processEvent（）方法
  2. public void processEvent(SimEvent ev) {
  3.         switch (ev.getTag()) {
  4.         // Resource characteristics request

  6.             case CloudSimTags.RESOURCE_CHARACTERISTICS_REQUEST:
  7.                 processResourceCharacteristicsRequest(ev);
  8.                 break;
  9.             // Resource characteristics answer

  11.             case CloudSimTags.RESOURCE_CHARACTERISTICS:
  12.                 processResourceCharacteristics(ev);
  13.                 break;
  14.             // VM Creation answer

  16.             case CloudSimTags.VM_CREATE_ACK:
  17.                 processVmCreate(ev);
  18.                 break;
  19.             // A finished cloudlet returned

  21.             case CloudSimTags.CLOUDLET_RETURN:
  22.                 processCloudletReturn(ev);
  23.                 break;
  24.             // if the simulation finishes

  26.             case CloudSimTags.END_OF_SIMULATION:
  27.                 shutdownEntity();
  28.                 break;
  29.             // other unknown tags are processed by this method

  31.             default:
  32.                 processOtherEvent(ev);
  33.                 break;
  34.         }
  35.     }

3、获取仿真运行时间，仿真完成，运行结束。

点击(此处)折叠或打开

  1. // 开始仿真直到结束仿真

  3.     public static double run() {
  4.         if (!running) {
  5.             runStart(); // 开始仿真，start所有实体

  7.         }
  8.         while (true) {
  9.             // 运行一个时钟心跳如果future中没有事件了，则runClockTick（）返回true，或者突然中断，while循环终止，仿真结束。
  10.             if (runClockTick() || abruptTerminate) {
  11.                 break;
  12.             }

  14.             // this block allows termination of simulation at a specific time
  15.             // 允许在特定的时间点终止仿真。
  16.             if (terminateAt > 0.0 && clock >= terminateAt) {
  17.                 terminateSimulation(); // 终止仿真

  19.                 clock = terminateAt;
  20.                 break;
  21.             }

  23.             // 在某一时刻（pauseAt）暂停仿真
  24.             if (pauseAt != -1
  25.                     && (
上一篇：Ceph:一个可扩展,高性能的分布式文件系统
下一篇：没有了