app/src/main/java/de/hems/trafficsim/MainActivity.java

@@ -18,7 +18,6 @@ public class MainActivity extends AppCompatActivity implements Observer, SeekBar
     public static final float defaultBrakeProb = 0.3f;
     public static final float defaultMaxVelocity = 5.0f;
     public static final int defaultDelay = 0;
-    public static final int defaultHistoryLength = 50;
     protected Track track;
     protected TimeRecordView trackView;
     protected Worker worker;
@@ -29,11 +28,9 @@ public class MainActivity extends AppCompatActivity implements Observer, SeekBar
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_main);
         this.track = new Track(defaultNoOfVehicles, defaultTrackLength, defaultBrakeProb,
-                defaultMaxVelocity, defaultDelay, defaultHistoryLength);
+                defaultMaxVelocity, defaultDelay);
         this.track.addObserver(this);
         this.viewStack = (LinearLayout) findViewById(R.id.trackViewStack);
-        this.trackView = new TimeRecordView(this, track, defaultHistoryLength);
-        viewStack.addView(this.trackView);
 
         SeekBar trackLengthSeekBar = (SeekBar) findViewById(R.id.trackLengthSeekBar);
         trackLengthSeekBar.setOnSeekBarChangeListener(this);
@@ -76,22 +73,18 @@ public class MainActivity extends AppCompatActivity implements Observer, SeekBar
         final TextView overallAvgView = (TextView) findViewById(R.id.avgVeloOverallView);
         final TextView delayedAvgView = (TextView) findViewById(R.id.delayedAvgTextView);
         final TextView stepsView = (TextView) findViewById(R.id.stepsTextView);
-        final TimeRecordView view = this.trackView;
         runOnUiThread(new Runnable() {
             @Override
             public void run() {
-
+                TimeRecordView newTrView = new TimeRecordView(mainActivity, trackRef);
-                //TimeRecordView newTrView = new TimeRecordView(mainActivity, trackRef);
+                if (viewStackRef.getChildCount() > 0)
-                trackView.invalidate();
+                    viewStackRef.removeViewAt(0);
-                //if (viewStackRef.getChildCount() > 0)
+                viewStackRef.addView(newTrView);
-                //    viewStackRef.removeViewAt(0);
-                //viewStackRef.addView(newTrView);
                 lastAvgView.setText(String.valueOf(round(trackRef.getLastAvg(), 2)));
                 overallAvgView.setText(String.valueOf(round(trackRef.getOverallAvg(), 2)));
-                stepsView.setText(String.valueOf(trackRef.getSteps()));
+                stepsView.setText(String.valueOf(trackRef.getVtrList().size()));
                 delayedAvgView.setText(String.valueOf(round(trackRef.getDelayedAvg(), 2)));
 
-
             }
         });
     }
@@ -179,8 +172,7 @@ public class MainActivity extends AppCompatActivity implements Observer, SeekBar
 
         int newDelay = ((SeekBar)(findViewById(R.id.simDelaySeekBar))).getProgress();
 
-        this.track = new Track(newNoOfVehicles, newTrackLength, newBrakeProb, newMaxVelocity, newDelay, defaultHistoryLength);
+        this.track = new Track(newNoOfVehicles, newTrackLength, newBrakeProb, newMaxVelocity, newDelay);
-        this.trackView.setTrack(this.track);
         this.track.addObserver(this);
         if (this.worker != null) { // There was a simulation running already
             this.stopWorker();

app/src/main/java/de/hems/trafficsim/TimeRecordView.java

@@ -5,6 +5,7 @@ import android.graphics.Canvas;
 import android.graphics.Color;
 import android.graphics.Paint;
 import android.view.View;
+import android.view.ViewGroup;
 
 import java.util.ConcurrentModificationException;
 import java.util.List;
@@ -13,23 +14,15 @@ public class TimeRecordView extends View {
     protected Paint paint;
     protected Track track;
     protected int pixelPerVehicle;
-    protected float tooShortPerTrackLength;
-    protected int historyLength;
 
-    public TimeRecordView(Context context, Track track, int historyLength) {
+    public TimeRecordView(Context context, Track track) {
         super(context);
         this.track = track;
         this.paint = new Paint();
-        this.historyLength = historyLength;
         paint.setColor(Color.BLACK);
         paint.setStyle(Paint.Style.FILL_AND_STROKE);
         this.setBackgroundColor(Color.BLACK);
         this.pixelPerVehicle = (int) (this.getWidth() / this.track.getTrackLength());
-        this.tooShortPerTrackLength = (this.getWidth() - this.pixelPerVehicle*this.track.getTrackLength())/this.track.getTrackLength();
-    }
-
-    public void setTrack(Track track) {
-        this.track = track;
     }
 
     protected int getColor(float curVelocity, float maxVelocity) {
@@ -59,32 +52,23 @@ public class TimeRecordView extends View {
     protected void onSizeChanged(int w, int h, int oldw, int oldh) {
         super.onSizeChanged(w, h, oldw, oldh);
         this.pixelPerVehicle = (int) (this.getWidth() / this.track.getTrackLength());
-        this.tooShortPerTrackLength = (this.getWidth() - this.pixelPerVehicle*this.track.getTrackLength())/this.track.getTrackLength();
     }
 
     @Override
     protected void onDraw(Canvas canvas) {
         int y = 0;
         List<List<VehicleTimeRecord>> stepList = this.track.getVtrList();
-        for (int curStepIdx = this.historyLength-1;
+        for (int curStepIdx = stepList.size()-1; curStepIdx >= stepList.size()-1-50 && curStepIdx >= 0; curStepIdx--) {
-             curStepIdx >= 0 && stepList.size() >= curStepIdx;
-             curStepIdx--) {
             try {
-                try {
-                    track.getListSemaphore().acquire();
-                } catch (InterruptedException ex) { return; }
                 List<VehicleTimeRecord> step = stepList.get(curStepIdx);
                 int i = 0;
                 for (VehicleTimeRecord r : step) {
                     int left = (int) (this.pixelPerVehicle * r.getPosition());
-                    int compensate = Math.round(r.getPosition()*this.tooShortPerTrackLength);
                     this.paint.setColor(getColor(r.getVelocity(), r.getMaxVelocity()));
-                    canvas.drawRect(left+compensate, y,
+                    canvas.drawRect(left, y, left + this.pixelPerVehicle - 1,
-                            left + this.pixelPerVehicle - 1+compensate,
                             y + 10, this.paint);
                     i++;
                 }
-                track.getListSemaphore().release();
                 y += 10;
             } catch (ConcurrentModificationException ex) {
                 System.out.println("Concurrent Exception occured, skipping record");

app/src/main/java/de/hems/trafficsim/Track.java

@@ -4,8 +4,6 @@ import java.util.ArrayList;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Observable;
-import java.util.concurrent.Semaphore;
-import java.util.concurrent.locks.LockSupport;
 
 public class Track extends Observable {
     protected List<Vehicle> vehicles;
@@ -20,8 +18,6 @@ public class Track extends Observable {
     protected int waitTime;
     protected float maxVelocity;
     protected float brakeProb;
-    protected long steps;
-    protected Semaphore listSemaphore;
 
     public List<List<VehicleTimeRecord>> getVtrList() { return vtrList; }
     public float getOverallAvg() {
@@ -37,10 +33,8 @@ public class Track extends Observable {
     public float getTrackLength() {
         return trackLength;
     }
-    public long getSteps() { return steps; }
-    public Semaphore getListSemaphore() { return listSemaphore; }
 
-    public Track(int numberVehicles, float trackLength, float brakeProb, float maxVelocity, int waitTime, int historyLength) {
+    public Track(int numberVehicles, float trackLength, float brakeProb, float maxVelocity, int waitTime) {
         this.trackLength = trackLength;
         this.brakeProb = brakeProb;
         this.maxVelocity = maxVelocity;
@@ -51,10 +45,8 @@ public class Track extends Observable {
         this.overallAvg = 0;
         this.delayedAvg = 0;
         this.lastAvg = 0;
-        this.historyLength = historyLength;
+        this.historyLength = 25;
         this.waitTime = waitTime;
-        this.steps = 0;
-        this.listSemaphore = new Semaphore(1);
 
     }
 
@@ -98,28 +90,17 @@ public class Track extends Observable {
             }
             v.updateVelocity(distanceForerunner);
         }
-
-        try {
-            this.listSemaphore.acquire();
-        } catch (InterruptedException ex) {return;}
         List <VehicleTimeRecord> records = new ArrayList<>(vehicles.size());
         this.vtrList.add(records);
-        if (this.vtrList.size() > this.historyLength) {
-            this.vtrList.remove(0);
-        }
         for(Vehicle v: vehicles){
             v.timeElapse();
             VehicleTimeRecord vtr = new VehicleTimeRecord(v.id, v.position, v.curVelocity, v.maxVelocity);
             records.add(vtr);
         }
-        steps++;
-        this.listSemaphore.release();
-
         update_avg();
         this.setChanged();
         this.notifyObservers();
         this.clearChanged();
-        LockSupport.parkNanos(1);
         try  {
             Thread.sleep(waitTime);
         } catch (InterruptedException ex) { }
@@ -135,12 +116,12 @@ public class Track extends Observable {
 
     protected void update_avg(){
         lastAvg = avg_step(vtrList.size()-1);
-        if (this.steps > 10) {
+        if (this.vtrList.size() > 10) {
             sumDelAvgMemory += lastAvg;
-            delayedAvg = sumDelAvgMemory / (this.steps - 10);
+            delayedAvg = sumDelAvgMemory / (vtrList.size() - 10);
         }
         sumAvgMemory += lastAvg;
-        overallAvg = sumAvgMemory / this.steps;
+        overallAvg = sumAvgMemory / vtrList.size();
 
     }
 

app/src/main/java/de/hems/trafficsim/Vehicle.java

@@ -46,6 +46,7 @@ public class Vehicle {
             curVelocity = curVelocity + 1;
         }
         if (r < brakeProb && curVelocity > 0) {
+            System.out.println("vehicle: "+brakeProb);
             curVelocity = curVelocity - 1;
         }
         if (curVelocity > distanceForerunner) {