source: xssim/trunk/src/example/localplugin/SJF_EBFLocalPlugin.java @ 104

package example.localplugin;

import gridsim.Gridlet;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Properties;

import schedframe.scheduling.Queue;
import schedframe.scheduling.TaskInterface;
import schedframe.scheduling.events.SchedulingEvent;
import schedframe.scheduling.plugin.local.ResourceUnitsManagerInterface;
import simulator.utils.MergeSort;

public class SJF_EBFLocalPlugin extends BaseLocalPlugin {

        public SJF_EBFLocalPlugin(){
        }
        
        public void schedule(SchedulingEvent event,
                        List<? extends TaskInterface<?>> inExecution,
                        List<? extends Queue<? extends TaskInterface<?>>> queues,
                        ResourceUnitsManagerInterface unitsManagerInterface) {
                
                // do this trick to make add() method available
                List <TaskInterface<?>> execute = (List<TaskInterface<?>>) inExecution;
                
                // chose the events types to serve. 
                // Different actions for different events are possible.
                switch(event.getType()){
                        //case START_TASK_EXECUTION:
                        //case TASK_FINISHED:
                        case TIMER:
                                // our tasks are placed only in first queue (see BaseLocalPlugin.placeTasksInQueues() method)
                                Queue<? extends TaskInterface<?>> q = queues.get(0);
                                
                                sortTasksInQueue(q);
                                
                                // check all tasks in queue
                                for(int i = 0; i < q.size(); i++){
                                        TaskInterface<?> task = q.get(i);
                                        // if status of the tasks in READY
                                        if(task.getStatus() == Gridlet.READY){
                                                // then try to execute this task. Add it the execute list.
                                                if(execute.add(task)){
                                                        // if task started successfully, then remove it from the queue.
                                                        q.remove(i);
                                                        i--;
                                                }
                                        }
                                }
                                break;
                }
                
        }

        public String getName() {
                return getClass().getName();
        }

        public void init(Properties properties) {
                // no extra initialization is expected.
        }
        
    public void sortTasksInQueue(Queue<? extends TaskInterface<?>> q) {
        
        TaskInterface<?>[] arrayQueue = new TaskInterface<?>[q.size()];
        int i = 0;
        for(TaskInterface<?> task: q){
                arrayQueue[i] = task;
                i++;
        }
        MergeSort mergeSort = new MergeSort();
        mergeSort.initSort(arrayQueue, "getLength", true);
        q.clear();
        q.addAll(new ArrayList(Arrays.asList(arrayQueue)));
    }

}