Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Introduces the SynchronousSimulationExample1 showing how to use feature
#205 Signed-off-by: Manoel Campos <manoelcampos@gmail.com>
- Loading branch information
1 parent
aa33cff
commit d16166e
Showing
1 changed file
with
179 additions
and
0 deletions.
There are no files selected for viewing
179 changes: 179 additions & 0 deletions
179
...-plus-examples/src/main/java/org/cloudsimplus/examples/SynchronousSimulationExample1.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,179 @@ | ||
/* | ||
* CloudSim Plus: A modern, highly-extensible and easier-to-use Framework for | ||
* Modeling and Simulation of Cloud Computing Infrastructures and Services. | ||
* http://cloudsimplus.org | ||
* | ||
* Copyright (C) 2015-2018 Universidade da Beira Interior (UBI, Portugal) and | ||
* the Instituto Federal de Educação Ciência e Tecnologia do Tocantins (IFTO, Brazil). | ||
* | ||
* This file is part of CloudSim Plus. | ||
* | ||
* CloudSim Plus is free software: you can redistribute it and/or modify | ||
* it under the terms of the GNU General Public License as published by | ||
* the Free Software Foundation, either version 3 of the License, or | ||
* (at your option) any later version. | ||
* | ||
* CloudSim Plus is distributed in the hope that it will be useful, | ||
* but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
* GNU General Public License for more details. | ||
* | ||
* You should have received a copy of the GNU General Public License | ||
* along with CloudSim Plus. If not, see <http://www.gnu.org/licenses/>. | ||
*/ | ||
package org.cloudsimplus.examples; | ||
|
||
import org.cloudbus.cloudsim.brokers.DatacenterBroker; | ||
import org.cloudbus.cloudsim.brokers.DatacenterBrokerSimple; | ||
import org.cloudbus.cloudsim.cloudlets.Cloudlet; | ||
import org.cloudbus.cloudsim.cloudlets.CloudletSimple; | ||
import org.cloudbus.cloudsim.core.CloudSim; | ||
import org.cloudbus.cloudsim.datacenters.Datacenter; | ||
import org.cloudbus.cloudsim.datacenters.DatacenterSimple; | ||
import org.cloudbus.cloudsim.hosts.Host; | ||
import org.cloudbus.cloudsim.hosts.HostSimple; | ||
import org.cloudbus.cloudsim.resources.Pe; | ||
import org.cloudbus.cloudsim.resources.PeSimple; | ||
import org.cloudbus.cloudsim.utilizationmodels.UtilizationModelDynamic; | ||
import org.cloudbus.cloudsim.vms.Vm; | ||
import org.cloudbus.cloudsim.vms.VmSimple; | ||
import org.cloudsimplus.builders.tables.CloudletsTableBuilder; | ||
|
||
import java.util.ArrayList; | ||
import java.util.List; | ||
|
||
/** | ||
* A example showing how to run the simulation synchronously, | ||
* (by calling {@link CloudSim#startSync()}). | ||
* This way, the researcher can interact with the simulation, | ||
* for instance to collect data. | ||
* | ||
* <p>A synchronous simulation is similar to setting a {@link Datacenter#setSchedulingInterval(double) scheduling interval}: | ||
* the simulation clock will be increased at the pace of the given interval. | ||
* However, using the {@link CloudSim#startSync()} we can collect | ||
* simulation data inside a loop, | ||
* without requiring to use {@link org.cloudsimplus.listeners.EventListener}s for that. | ||
* </p> | ||
* | ||
* @author Pawel Koperek | ||
* @author Manoel Campos da Silva Filho | ||
* @since CloudSim Plus 4.5.0 | ||
*/ | ||
public class SynchronousSimulationExample1 { | ||
/** | ||
* Defines the time (in seconds) to run the simulation for. | ||
* The clock is increased in the interval defined here. | ||
*/ | ||
private static final double INTERVAL = 2; | ||
private static final int HOSTS = 2; | ||
private static final int HOST_PES = 4; | ||
|
||
private static final int VMS = 4; | ||
private static final int VM_PES = 2; | ||
|
||
private static final int CLOUDLETS = 4; | ||
private static final int CLOUDLET_PES = 2; | ||
private static final int CLOUDLET_LENGTH = 10000; | ||
|
||
private final CloudSim simulation; | ||
private DatacenterBroker broker0; | ||
private List<Vm> vmList; | ||
private List<Cloudlet> cloudletList; | ||
private Datacenter datacenter0; | ||
|
||
public static void main(String[] args) { | ||
new SynchronousSimulationExample1(); | ||
} | ||
|
||
public SynchronousSimulationExample1() { | ||
/*Enables just some level of log messages. | ||
Make sure to import org.cloudsimplus.util.Log;*/ | ||
//Log.setLevel(ch.qos.logback.classic.Level.WARN); | ||
|
||
simulation = new CloudSim(); | ||
datacenter0 = createDatacenter(); | ||
|
||
//Creates a broker that is a software acting on behalf a cloud customer to manage his/her VMs and Cloudlets | ||
broker0 = new DatacenterBrokerSimple(simulation); | ||
|
||
vmList = createVms(); | ||
cloudletList = createCloudlets(); | ||
broker0.submitVmList(vmList); | ||
broker0.submitCloudletList(cloudletList); | ||
|
||
simulation.startSync(); | ||
//TODO: To know if the simulation must finish, it has to be checked the future.isEmpty(), terminationTime and abortRequested | ||
while(simulation.isRunning()){ | ||
simulation.runFor(INTERVAL); | ||
} | ||
|
||
final List<Cloudlet> finishedCloudlets = broker0.getCloudletFinishedList(); | ||
new CloudletsTableBuilder(finishedCloudlets).build(); | ||
} | ||
|
||
/** | ||
* Creates a Datacenter and its Hosts. | ||
*/ | ||
private Datacenter createDatacenter() { | ||
final List<Host> hostList = new ArrayList<>(HOSTS); | ||
for(int i = 0; i < HOSTS; i++) { | ||
Host host = createHost(); | ||
hostList.add(host); | ||
} | ||
|
||
//Uses a VmAllocationPolicySimple by default to allocate VMs | ||
return new DatacenterSimple(simulation, hostList); | ||
} | ||
|
||
private Host createHost() { | ||
final List<Pe> peList = new ArrayList<>(HOST_PES); | ||
//List of Host's CPUs (Processing Elements, PEs) | ||
for (int i = 0; i < HOST_PES; i++) { | ||
//Uses a PeProvisionerSimple by default to provision PEs for VMs | ||
peList.add(new PeSimple(1000)); | ||
} | ||
|
||
final long ram = 2048; //in Megabytes | ||
final long bw = 10000; //in Megabits/s | ||
final long storage = 1000000; //in Megabytes | ||
|
||
/* | ||
Uses ResourceProvisionerSimple by default for RAM and BW provisioning | ||
and VmSchedulerSpaceShared for VM scheduling. | ||
*/ | ||
return new HostSimple(ram, bw, storage, peList); | ||
} | ||
|
||
/** | ||
* Creates a list of VMs. | ||
*/ | ||
private List<Vm> createVms() { | ||
final List<Vm> list = new ArrayList<>(VMS); | ||
for (int i = 0; i < VMS; i++) { | ||
//Uses a CloudletSchedulerTimeShared by default to schedule Cloudlets | ||
final Vm vm = new VmSimple(1000, VM_PES); | ||
vm.setRam(512).setBw(1000).setSize(10000); | ||
list.add(vm); | ||
} | ||
|
||
return list; | ||
} | ||
|
||
/** | ||
* Creates a list of Cloudlets. | ||
*/ | ||
private List<Cloudlet> createCloudlets() { | ||
final List<Cloudlet> list = new ArrayList<>(CLOUDLETS); | ||
|
||
//UtilizationModel defining the Cloudlets use only 50% of any resource all the time | ||
final UtilizationModelDynamic utilizationModel = new UtilizationModelDynamic(0.5); | ||
|
||
for (int i = 0; i < CLOUDLETS; i++) { | ||
final Cloudlet cloudlet = new CloudletSimple(CLOUDLET_LENGTH, CLOUDLET_PES, utilizationModel); | ||
cloudlet.setSizes(1024); | ||
list.add(cloudlet); | ||
} | ||
|
||
return list; | ||
} | ||
} |