Package cambio.simulator.resources.cpu

Class CPU

java.lang.Object

desmoj.core.simulator.NamedObject

desmoj.core.simulator.ModelComponent

desmoj.core.simulator.Schedulable

desmoj.core.simulator.EventAbstract

desmoj.core.simulator.ExternalEvent

cambio.simulator.entities.NamedExternalEvent

cambio.simulator.resources.cpu.CPU

public class CPU
extends NamedExternalEvent

Represents a CPU resource.

The CPU implementation supports multithreading with a thread pool size and multiple scheduling strategies.

Author:

Lion Wagner

See Also:

• CPUProcess
• CPUProcessScheduler
• CPU(Model, String, boolean, MicroserviceInstance, int, CPUProcessScheduler, int)

Field Summary

Fields inherited from class desmoj.core.simulator.EventAbstract

numberOfEntities

Fields inherited from class desmoj.core.simulator.Schedulable

_schedule

Constructor Summary

Constructors

Constructor	Description
CPU(desmoj.core.simulator.Model model, String name, boolean showInTrace, int capacity, int threadPoolSize, MicroserviceInstance owner)	Constructs a new CPU with a default Round-Robin scheduler.
CPU(desmoj.core.simulator.Model model, String name, boolean showInTrace, int capacity, MicroserviceInstance owner)	Constructs a new CPU with a default Round-Robin scheduler and a default thread pool size of CPUImpl.DEFAULT_THREADPOOLSIZE.
CPU(desmoj.core.simulator.Model model, String name, boolean showInTrace, int capacity, CPUProcessScheduler scheduler, MicroserviceInstance owner)	Constructs a new CPU with a default thread pool size of CPUImpl.DEFAULT_THREADPOOLSIZE.
CPU(desmoj.core.simulator.Model model, String name, boolean showInTrace, MicroserviceInstance owner, int capacity, CPUProcessScheduler scheduler, int threadPoolSize)	Constructs a new CPU resource instance.

Method Summary

Modifier and Type	Method	Description
void	clear()	Forcibly stops all currently running and scheduled processes.
double	getCurrentRelativeWorkDemand()	Calculates the relative remaining workload demand of this CPU.
double	getCurrentUsage()
void	onRoutineExecution()	Generic routine of the CPU implementation.
void	submitProcess(CPUProcess process)	Schedules the given process to be executed.

Methods inherited from class cambio.simulator.entities.NamedExternalEvent

eventRoutine, getPlainName, getQuotedName, getQuotedPlainName, rename

Methods inherited from class desmoj.core.simulator.ExternalEvent

clone, schedule, schedule, schedule, schedule, scheduleAfter, scheduleBefore, schedulePreempt

Methods inherited from class desmoj.core.simulator.EventAbstract

generateTraceForScheduling, getNumberOfEntities, getRealTimeConstraint, getSchedulingPriority, isExternal, setRealTimeConstraint, setSchedulingPriority

Methods inherited from class desmoj.core.simulator.Schedulable

assignReporter, cancel, getCorrespondingReportable, isCurrent, isScheduled, reSchedule, reSchedule, reSchedulePreempt, scheduledNext, setCorrespondingReportable

Methods inherited from class desmoj.core.simulator.ModelComponent

current, currentEntity, currentEntityAll, currentEvent, currentlySendDebugNotes, currentlySendTraceNotes, currentModel, currentSimProcess, debugIsOn, debugOff, debugOn, getModel, isExperimentCompatible, isModelCompatible, presentTime, sendDebugNote, sendMessage, sendTraceNote, sendWarning, skipTraceNote, skipTraceNote, traceIsOn, traceOff, traceOn

Methods inherited from class desmoj.core.simulator.NamedObject

getName, toString

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

CPU

public CPU(desmoj.core.simulator.Model model,
 String name,
 boolean showInTrace,
 int capacity,
 MicroserviceInstance owner)

Constructs a new CPU with a default Round-Robin scheduler and a default thread pool size of CPUImpl.DEFAULT_THREADPOOLSIZE.

See Also:

• CPU(desmoj.core.simulator.Model, java.lang.String, boolean, cambio.simulator.entities.microservice.MicroserviceInstance, int, cambio.simulator.resources.cpu.scheduling.CPUProcessScheduler, int)
• RoundRobinScheduler

CPU

public CPU(desmoj.core.simulator.Model model,
 String name,
 boolean showInTrace,
 int capacity,
 int threadPoolSize,
 MicroserviceInstance owner)

Constructs a new CPU with a default Round-Robin scheduler.

See Also:

• CPU(desmoj.core.simulator.Model, java.lang.String, boolean, cambio.simulator.entities.microservice.MicroserviceInstance, int, cambio.simulator.resources.cpu.scheduling.CPUProcessScheduler, int)
• RoundRobinScheduler

CPU

public CPU(desmoj.core.simulator.Model model,
 String name,
 boolean showInTrace,
 int capacity,
 CPUProcessScheduler scheduler,
 MicroserviceInstance owner)

Constructs a new CPU with a default thread pool size of CPUImpl.DEFAULT_THREADPOOLSIZE.

See Also:

• CPU(desmoj.core.simulator.Model, java.lang.String, boolean, cambio.simulator.entities.microservice.MicroserviceInstance, int, cambio.simulator.resources.cpu.scheduling.CPUProcessScheduler, int)

CPU

public CPU(desmoj.core.simulator.Model model,
 String name,
 boolean showInTrace,
 MicroserviceInstance owner,
 int capacity,
 CPUProcessScheduler scheduler,
 int threadPoolSize)

Constructs a new CPU resource instance.

Parameters:

model - parent and simulation model

name - CPU name

showInTrace - whether the computation events should be shown in the trace

owner - instance that owns this cpu

capacity - total capacity of the cpu resource. Each thread will be assigned a capacity of Math.floor(capacity/threadPoolSize).

scheduler - implementation of a scheduling strategy that should be used by the CPU

threadPoolSize - thread count of the CPU

See Also:

• CPUProcessScheduler
• RoundRobinScheduler

Method Details

submitProcess

public void submitProcess(CPUProcess process)

Schedules the given process to be executed.

Depending on the choice of scheduler (fair/unfair) the execution is not guaranteed.

Parameters:

process - CPUProcess object to be submitted for scheduling

See Also:

• CPUProcess
• CPUProcessScheduler

onRoutineExecution

public void onRoutineExecution()
                        throws co.paralleluniverse.fibers.SuspendExecution

Generic routine of the CPU implementation.

As long as processes can be scheduled, the cpu retrieves the next process and target burst duration from the scheduler. Based on the retrieved data a ComputationBurstCompletedEvent is scheduled to execute after the target burst duration.

ComputationBurstCompletedEvents will notify this object about this object about their execution via the CPUImpl#onBurstFinished method.

Specified by:

onRoutineExecution in class NamedExternalEvent

Throws:

co.paralleluniverse.fibers.SuspendExecution

See Also:

• ComputationBurstCompletedEvent

clear

public void clear()

Forcibly stops all currently running and scheduled processes.

getCurrentRelativeWorkDemand

public double getCurrentRelativeWorkDemand()

Calculates the relative remaining workload demand of this CPU.

This demand is calculated by (queuedDemand + activeDemand)/(totalCapacity)

Returns:

the remaining amount of cycles to complete the current workload

getCurrentUsage

public double getCurrentUsage()