Generator atomic model

src/AMGenerator.java

+package carfollowing_2024_05_02;
+
+import java.io.BufferedReader;
+import java.io.FileReader;
+import java.io.IOException;
+
+import DEVSModel.DEVSAtomic;
+import DEVSModel.Port;
+
+public class AMGenerator extends DEVSAtomic {
+	
+	Port carGen;
+	
+	enum Phase {generate, stop};
+	Phase phase;
+	
+	private float sigma, time;
+	
+	static int numCar = 10;
+	static int numTestFile = 9;
+	
+	static String test = "input/input";
+	static String filePath = test+String.valueOf(numCar)+"_"+String.valueOf(numTestFile)+".txt";
+	
+	String line = "";
+	BufferedReader reader = null;
+	
+	public AMGenerator(String name) {
+		this.name = name;
+		carGen = new Port(this, "car_generated");
+		this.addOutPort(carGen);
+		
+		// 2024_04_17 read input from file
+		try {
+			reader = new BufferedReader(new FileReader(filePath));
+			reader.readLine();				// Read header line
+		} catch (IOException ex) {
+				ex.printStackTrace();
+		} 
+	}
+	
+	@Override
+	public void deltaExt(Port arg0, Object arg1, float arg2) {
+		// nothing to do
+		
+	}
+	
+	@Override
+	public void deltaInt() {		
+//		if (countCar < numCar) {
+//			countCar ++;
+//		}
+//		else phase = Phase.stop;		
+		
+		// 2024_04_17 
+		System.out.println("---deltaInt---" + this.name);
+		
+		try {
+			line = reader.readLine();				
+		} catch (IOException ex) {
+				ex.printStackTrace();
+		}	
+		
+		if (line == null)
+			phase = Phase.stop;
+		
+		System.out.println(phase);
+	}
+
+	@Override
+	public float getDuration() {
+		// 2024_04_17 edit for input duration time
+//		System.out.println("---getDuration---" + this.name);
+		
+		if (phase == Phase.stop) return Float.POSITIVE_INFINITY;
+		else {
+			String[] fields = line.split(" ");
+			return Integer.parseInt(fields[0]);
+		}
+	}
+
+	@Override
+	public void init() {
+		/* Init state: Generate */
+		
+		phase = Phase.generate;
+		time = 0;
+		sigma = 0;
+		
+		try {
+			line = reader.readLine();				
+		} catch (IOException ex) {
+				ex.printStackTrace();
+		} 
+		
+		if (line != null) {
+			String[] fields = line.split(" ");
+			sigma = Integer.parseInt(fields[0]);
+		}
+	}
+
+	@Override
+	public Object[] lambda() {
+		/* Output an object include:
+		 * obj[0] : port
+		 * obj[1] : carGen object with id, init speed, departure time */
+		
+		// Test 2024_04_17 read input from files
+		time += getDuration();
+		System.out.println("---lamda---" + this.name);
+		System.out.println("Time: " + time);
+		
+		String id = "";
+		int speed = 0;
+		
+		String[] fields = line.split(" ");
+
+		id = fields[1];
+		speed = Integer.parseInt(fields[2]);
+				
+		System.out.println("*** Car("+id+") generated");
+		Object[] obj = new Object[2];
+		obj[0] = this.carGen; 	
+		obj[1] = new Car(id, speed, time);
+			
+		return obj;
+	}
+}