X-Git-Url: https://mograsim.net/gitweb/?a=blobdiff_plain;f=era.mi%2Fsrc%2Fera%2Fmi%2Flogic%2Ftimeline%2FTimeline.java;h=7030310b4621b524a94f85ad24300d1b5a211d36;hb=74aebd92f41d03f4a44c9a455ef8c05465136412;hp=3e3b9f6d94248edc6349bc8d062de7eeb3ecbf39;hpb=de79184d60c80d6775b368e61d3368de032952e8;p=Mograsim.git diff --git a/era.mi/src/era/mi/logic/timeline/Timeline.java b/era.mi/src/era/mi/logic/timeline/Timeline.java index 3e3b9f6d..7030310b 100644 --- a/era.mi/src/era/mi/logic/timeline/Timeline.java +++ b/era.mi/src/era/mi/logic/timeline/Timeline.java @@ -7,68 +7,58 @@ import java.util.function.Consumer; /** * Orders Events by the time they are due to be executed. Can execute Events individually. + * * @author Fabian Stemmler * */ -public class Timeline -{ +public class Timeline { private PriorityQueue events; private long currentTime = 0; - + private final List> eventAddedListener; - - public Timeline(int initCapacity) - { + + public Timeline(int initCapacity) { events = new PriorityQueue(initCapacity, (a, b) -> { long difference = a.getTiming() - b.getTiming(); - if(difference == 0) + if (difference == 0) return 0; return difference < 0 ? -1 : 1; }); - + eventAddedListener = new ArrayList<>(); } - - public boolean hasNext() - { + + public boolean hasNext() { return !events.isEmpty(); } - public void executeNext() - { + public void executeNext() { InnerEvent first = events.poll(); currentTime = first.getTiming(); first.run(); } - - public void executeAll() - { + + public void executeAll() { while (hasNext()) executeNext(); } - + /** - * Executes all events up to a given simulation timestamp. The simulation - * process can be constrained by a real world timestamp. + * Executes all events up to a given simulation timestamp. The simulation process can be constrained by a real world timestamp. * - * @param timestamp the simulation timestamp up to which the events will be - * processed - * @param stopMillis the System.currentTimeMillis() when simulation definitely - * needs to stop. + * @param timestamp the simulation timestamp up to which the events will be processed + * @param stopMillis the System.currentTimeMillis() when simulation definitely needs to stop. * @return if it was possible to fulfil the goal in the given real world time. * @author Christian Femers */ - public ExecutionResult executeUpTo(long timestamp, long stopMillis) - { - if (events.isEmpty()) - { + public ExecutionResult executeUpTo(long timestamp, long stopMillis) { + if (events.isEmpty()) { currentTime = timestamp; return ExecutionResult.NOTHING_DONE; } int checkStop = 0; InnerEvent first = events.peek(); - while (first != null && first.getTiming() <= timestamp) - { + while (first != null && first.getTiming() <= timestamp) { events.remove(); currentTime = first.getTiming(); first.run(); @@ -82,96 +72,85 @@ public class Timeline return ExecutionResult.DONE_IN_TIME; } - public long getSimulationTime() - { + public long getSimulationTime() { return currentTime; } - public long nextEventTime() - { - if(!hasNext()) + public long nextEventTime() { + if (!hasNext()) return -1; else return events.peek().timing; } - - public void reset() - { + + public void reset() { events.clear(); currentTime = 0; } - public void addEventAddedListener(Consumer listener) - { + public void addEventAddedListener(Consumer listener) { eventAddedListener.add(listener); } - public void removeEventAddedListener(Consumer listener) - { + + public void removeEventAddedListener(Consumer listener) { eventAddedListener.remove(listener); } - + /** * Adds an Event to the {@link Timeline} - * @param function The {@link TimelineEventHandler} that will be executed, when the {@link InnerEvent} occurs on the timeline. + * + * @param function The {@link TimelineEventHandler} that will be executed, when the {@link InnerEvent} occurs on the timeline. * @param relativeTiming The amount of MI ticks in which the {@link InnerEvent} is called, starting from the current time. */ - public void addEvent(TimelineEventHandler function, int relativeTiming) - { + public void addEvent(TimelineEventHandler function, int relativeTiming) { long timing = currentTime + relativeTiming; TimelineEvent event = new TimelineEvent(timing); events.add(new InnerEvent(function, event, timing)); eventAddedListener.forEach(l -> l.accept(event)); } - - private class InnerEvent - { + + private class InnerEvent { private final long timing; private final TimelineEventHandler function; private final TimelineEvent event; - + /** * Creates an {@link InnerEvent} + * * @param function {@link TimelineEventHandler} to be executed when the {@link InnerEvent} occurs - * @param timing Point in the MI simulation {@link Timeline}, at which the {@link InnerEvent} is executed; + * @param timing Point in the MI simulation {@link Timeline}, at which the {@link InnerEvent} is executed; */ - InnerEvent(TimelineEventHandler function, TimelineEvent event, long timing) - { + InnerEvent(TimelineEventHandler function, TimelineEvent event, long timing) { this.function = function; this.event = event; this.timing = timing; } - public long getTiming() - { + public long getTiming() { return timing; } - - public void run() - { + + public void run() { function.handle(event); } - + @Override - public String toString() - { + public String toString() { return event.toString(); } } - + @Override - public String toString() - { + public String toString() { return "simulation time: " + currentTime + ", " + events.toString(); } - - public static long toNanoseconds(long ticks) - { - return ticks; //TODO: Alter this when it has been determined how ticks should relate to real time. + + public static long toNanoseconds(long ticks) { + return ticks; // TODO: Alter this when it has been determined how ticks should relate to real time. } - - public enum ExecutionResult - { - NOTHING_DONE, DONE_IN_TIME, RAN_OUT_OF_TIME + + public enum ExecutionResult { + NOTHING_DONE, DONE_IN_TIME, RAN_OUT_OF_TIME } } \ No newline at end of file