Inheritance diagram for org.matsim.withinday.trafficmonitoring.WithinDayTravelTime:

[legend]

Classes
class	TravelTimeInfo

class	TripBin

class	UpdateMeanTravelTimesRunnable

Public Member Functions
	WithinDayTravelTime (Scenario scenario, Set< String > analyzedModes)

final void	addNetworkChangeEvent (NetworkChangeEvent networkChangeEvent)

double	getLinkTravelTime (Link link, double time, Person person, Vehicle vehicle)

void	reset (int iteration)

void	handleEvent (LinkEnterEvent event)

void	handleEvent (LinkLeaveEvent event)

void	handleEvent (PersonStuckEvent event)

void	handleEvent (VehicleLeavesTrafficEvent event)

void	handleEvent (VehicleEntersTrafficEvent event)

void	notifyMobsimInitialized (MobsimInitializedEvent e)

void	notifyMobsimAfterSimStep (MobsimAfterSimStepEvent e)

void	notifyMobsimBeforeSimStep (MobsimBeforeSimStepEvent e)

void	notifyMobsimBeforeCleanup (MobsimBeforeCleanupEvent e)

Private Member Functions
void	init ()

void	addNetworkChangeEventToLocalDataStructure (NetworkChangeEvent networkChangeEvent)

void	printInfo (double time)

void	run (double time)

void	initParallelThreads ()

Private Attributes
Network	network

Map< Id< Vehicle >, TripBin >	regularActiveTrips

Map< Id< Link >, TravelTimeInfo >	travelTimeInfos

TravelTimeInfoProvider	travelTimeInfoProvider

TreeMap< Double, Map< Link, Double > >	changedLinksByTime

CyclicBarrier	startBarrier

CyclicBarrier	endBarrier

UpdateMeanTravelTimesRunnable []	updateMeanTravelTimesRunnables

final int	numOfThreads

final int	infoTimeStep = 3600

int	nextInfoTime = 0

Set< Id< Vehicle > >	vehiclesToFilter

final Set< String >	analyzedModes

final boolean	filterModes

boolean	problem = true

int	resetCnt = 0

double	now = Double.NEGATIVE_INFINITY

Static Private Attributes
static final Logger	log = LogManager.getLogger(WithinDayTravelTime.class)

Detailed Description

Collects link travel times over a given time span (storedTravelTimesBinSize) and calculates an average travel time over this time span.

TODO:

make storedTravelTimesBinSize configurable (e.g. via config)

Author: cdobler

Definition at line 86 of file WithinDayTravelTime.java.

Constructor & Destructor Documentation

◆ WithinDayTravelTime()

org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.WithinDayTravelTime	(	Scenario	scenario,
		Set< String >	analyzedModes
	)

Definition at line 131 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.analyzedModes, org.matsim.api.core.v01.Scenario.getConfig(), org.matsim.api.core.v01.Scenario.getNetwork(), org.matsim.core.config.groups.GlobalConfigGroup.getNumberOfThreads(), org.matsim.core.config.Config.global(), and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.init().

                                                                              {
 //      log.setLevel(Level.DEBUG);
 
         /*
          * The parallelization should scale almost linear, therefore we do use
          * the number of available threads according to the config file.
          */
         this.network = scenario.getNetwork();
         this.numOfThreads = scenario.getConfig().global().getNumberOfThreads();
 
         if (analyzedModes == null || analyzedModes.size() == 0) {
             this.filterModes = false;
             this.analyzedModes = null;
         } else {
             this.analyzedModes = new HashSet<>(analyzedModes);
             filterModes = true;
         }
 
         init();
     }

Here is the call graph for this function:

Member Function Documentation

◆ init()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.init ( )

private

Definition at line 152 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.addNetworkChangeEventToLocalDataStructure(), org.matsim.api.core.v01.network.Network.getLinks(), and org.matsim.core.network.NetworkUtils.getNetworkChangeEvents().

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.reset(), and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.WithinDayTravelTime().

                         {
         this.regularActiveTrips = new HashMap<>();
         this.travelTimeInfos = new ConcurrentHashMap<>();
         this.changedLinksByTime = new TreeMap<>();
         this.vehiclesToFilter = new HashSet<>();
 
         // one TravelTimeInfo per link:
         for (Link link : this.network.getLinks().values()) {
             TravelTimeInfo travelTimeInfo = new TravelTimeInfo();
             this.travelTimeInfos.put(link.getId(), travelTimeInfo);
         }
 
         /*
          * If no RoutingNetwork is used, ArrayBasedTravelTimeInfoProvider uses
          * a MapBasedTravelTimeInfoProvider as fall back solution. This increases
          * routing times of a AStarLandmarks router by ~5%.
          */
 //      this.travelTimeInfoProvider = new MapBasedTravelTimeInfoProvider(this.travelTimeInfos);
         this.travelTimeInfoProvider = new ArrayBasedTravelTimeInfoProvider(this.travelTimeInfos, this.network);
 
         /*
          * If the network is time variant, we have to update the link parameters
          * according to the network change events.
          */
         Queue<NetworkChangeEvent> networkChangeEvents = NetworkUtils.getNetworkChangeEvents(this.network);
 
         // I just changed the return type of the network change events from Collection to Queue.
         // This should, in a first step, allow to remove the separate changedLinksByTime data structure.
         // In a second step, this should allow to insert link change events after everything
         // has started.  kai, dec'17
         // Well, but maybe I don't even want this, and I want this class here recognize changes
         // only when someone observes them??? (bushfire evacuation use case). kai, dec'17
 
         // If one looks at transport telematics, then we need to also be able to set expected
         // speeds for the future!  Which would indeed justify its own data model.  kai, dec'17
         // (in contrast, watch out: the NetworkChangeEventsEngine also keeps its own
         // copy for the mobsim)
 
         if (networkChangeEvents != null) {
             for (NetworkChangeEvent networkChangeEvent : networkChangeEvents) {
                 addNetworkChangeEventToLocalDataStructure(networkChangeEvent);
             }
         }
     }

Here is the call graph for this function:

◆ addNetworkChangeEventToLocalDataStructure()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.addNetworkChangeEventToLocalDataStructure ( NetworkChangeEvent networkChangeEvent )

private

Definition at line 197 of file WithinDayTravelTime.java.

References org.matsim.core.network.NetworkChangeEvent.getFreespeedChange(), org.matsim.core.network.NetworkChangeEvent.getLinks(), org.matsim.core.network.NetworkChangeEvent.getStartTime(), org.matsim.core.network.NetworkChangeEvent.ChangeValue.getType(), and org.matsim.core.network.NetworkChangeEvent.ChangeValue.getValue().

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.addNetworkChangeEvent(), and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.init().

                                                                                                   {
         ChangeValue freespeedChange = networkChangeEvent.getFreespeedChange();
         if (freespeedChange != null) {
             double startTime = networkChangeEvent.getStartTime();
             Map<Link,Double> newLinkSpeedsAtThisTime = changedLinksByTime.computeIfAbsent(startTime, k -> new HashMap<>());
             for ( Link link : networkChangeEvent.getLinks() ) {
                 // yy seems that the following should be available centrally. kai, dec'17
                 double newSpeed ;
                 switch ( freespeedChange.getType() ) {
                     case ABSOLUTE_IN_SI_UNITS:
                         newSpeed = freespeedChange.getValue() ;
                         break;
                     case FACTOR:
                         newSpeed = link.getFreespeed() * freespeedChange.getValue() ;
                         break;
                     case OFFSET_IN_SI_UNITS:
                         newSpeed = link.getFreespeed() + freespeedChange.getValue() ;
                         break;
                     default:
                         throw new RuntimeException("change event type not implemented") ;
                 }
                 if ( startTime > 0. ) {
                     log.debug( "registering a change event for time=" + startTime
                     + "; linkId=" + link.getId() ) ;
                 }
                 newLinkSpeedsAtThisTime.put( link, newSpeed ) ;
             }
         }
     }

Here is the call graph for this function:

◆ addNetworkChangeEvent()

final void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.addNetworkChangeEvent ( NetworkChangeEvent networkChangeEvent )

Definition at line 227 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.addNetworkChangeEventToLocalDataStructure().

                                                                                    {
         this.addNetworkChangeEventToLocalDataStructure(networkChangeEvent);
     }

Here is the call graph for this function:

◆ getLinkTravelTime()

double org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.getLinkTravelTime	(	Link	link,
		double	time,
		Person	person,
		Vehicle	vehicle
	)

Returns the travel time for the specified link at the specified time.

Parameters

link	The link for which the travel time is calculated.
time	The departure time (in seconds since 00:00) at the beginning of the link for which the travel time is calculated.
person	TODO
vehicle	TODO

Returns: The time (in seconds) needed to travel over the link link, departing at time time.

Implements org.matsim.core.router.util.TravelTime.

Definition at line 232 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.TravelTimeInfoProvider.getTravelTimeInfo().

                                                                                             {
         final double travelTime = this.travelTimeInfoProvider.getTravelTimeInfo(link).travelTime;
         return travelTime;
     }

Here is the call graph for this function:

◆ reset()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.reset ( int iteration )

Gives the event handler the possibility to clean up its internal state. Within a Controler-Simulation, this is called before the mobsim starts.

Parameters

iteration the up-coming iteration from which up-coming events will be from.

Implements org.matsim.core.events.handler.EventHandler.

Definition at line 238 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.init().

                                      {
         init();
         resetCnt++ ;
         if ( resetCnt >1 ) {
             if ( problem ) {
                 throw new RuntimeException("using WithinDayTravelTime, but mobsim notifications not called between two resets.  "
                         + "Did you really add this as a mobsim listener?") ;
             }
         }
     }

Here is the call graph for this function:

◆ handleEvent() [1/5]

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.handleEvent ( LinkEnterEvent event )

Implements org.matsim.api.core.v01.events.handler.LinkEnterEventHandler.

Definition at line 250 of file WithinDayTravelTime.java.

References org.matsim.api.core.v01.events.LinkEnterEvent.getVehicleId().

                                                   {
         /*
          * If only some modes are analyzed, we check whether the vehicle
          * performs a trip with one of those modes. if not, we skip the event.
          */
         if (filterModes && vehiclesToFilter.contains(event.getVehicleId())) return;
 
         Id<Vehicle> vehicleId = event.getVehicleId();
         double time = event.getTime();
 
         TripBin tripBin = new TripBin();
         tripBin.enterTime = time;
 
         this.regularActiveTrips.put(vehicleId, tripBin);
     }

Here is the call graph for this function:

◆ handleEvent() [2/5]

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.handleEvent ( LinkLeaveEvent event )

Implements org.matsim.api.core.v01.events.handler.LinkLeaveEventHandler.

Definition at line 267 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.TravelTimeInfoProvider.getTravelTimeInfo().

                                                   {
         Id<Link> linkId = event.getLinkId();
         Id<Vehicle> vehicleId = event.getVehicleId();
         double time = event.getTime();
 
         TripBin tripBin = this.regularActiveTrips.remove(vehicleId);
         if (tripBin != null) {
             tripBin.leaveTime = time;
 
             double tripTime = tripBin.leaveTime - tripBin.enterTime;
 
             TravelTimeInfo travelTimeInfo = this.travelTimeInfoProvider.getTravelTimeInfo(linkId);
             travelTimeInfo.tripBins.add(tripBin);
             travelTimeInfo.addedTravelTimes += tripTime;
             travelTimeInfo.addedTrips++;
 
             travelTimeInfo.checkActiveState();
             travelTimeInfo.checkBinSize(tripTime);
         }
     }

Here is the call graph for this function:

◆ handleEvent() [3/5]

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.handleEvent ( PersonStuckEvent event )

Implements org.matsim.api.core.v01.events.handler.PersonStuckEventHandler.

Definition at line 293 of file WithinDayTravelTime.java.

                                                     {
 
     }

◆ handleEvent() [4/5]

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.handleEvent ( VehicleLeavesTrafficEvent event )

Implements org.matsim.api.core.v01.events.handler.VehicleLeavesTrafficEventHandler.

Definition at line 303 of file WithinDayTravelTime.java.

References org.matsim.api.core.v01.events.VehicleLeavesTrafficEvent.getVehicleId().

                                                              {
         Id<Vehicle> vehicleId = event.getVehicleId();
 
         this.regularActiveTrips.remove(vehicleId);
 
         // try to remove vehicle from set with filtered vehicles
         if (filterModes) this.vehiclesToFilter.remove(event.getVehicleId());
     }

Here is the call graph for this function:

◆ handleEvent() [5/5]

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.handleEvent ( VehicleEntersTrafficEvent event )

Implements org.matsim.api.core.v01.events.handler.VehicleEntersTrafficEventHandler.

Definition at line 313 of file WithinDayTravelTime.java.

References org.matsim.api.core.v01.events.VehicleEntersTrafficEvent.getNetworkMode(), and org.matsim.api.core.v01.events.VehicleEntersTrafficEvent.getVehicleId().

                                                              {
         /*
          * If filtering transport modes is enabled and the vehicle
          * starts a leg on a non analyzed transport mode, add the vehicle
          * to the filtered vehicles set.
          */
         if (filterModes && !analyzedModes.contains(event.getNetworkMode())) this.vehiclesToFilter.add(event.getVehicleId());
     }

Here is the call graph for this function:

◆ notifyMobsimInitialized()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimInitialized ( MobsimInitializedEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimInitializedListener.

Definition at line 326 of file WithinDayTravelTime.java.

References org.matsim.api.core.v01.network.Network.getLinks(), org.matsim.withinday.trafficmonitoring.TravelTimeInfoProvider.getTravelTimeInfo(), org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.infoTimeStep, and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.initParallelThreads().

                                                                   {
         problem = false ;
 
         if (e.getQueueSimulation() instanceof QSim) {
             double simStartTime = ((QSim) e.getQueueSimulation()).getSimTimer().getSimStartTime();
 
             /*
              * infoTime may be < simStartTime, this ensures to print
              * out the info at the very first timestep already
              */
             this.nextInfoTime = (int)(Math.floor(simStartTime / this.infoTimeStep) * this.infoTimeStep);
         }
 
 
         for (Link link : this.network.getLinks().values()) {
             double freeSpeedTravelTime = link.getLength() / link.getFreespeed();
 
             TravelTimeInfo travelTimeInfo = this.travelTimeInfoProvider.getTravelTimeInfo(link);
             travelTimeInfo.travelTime = freeSpeedTravelTime;
             travelTimeInfo.init(freeSpeedTravelTime);
         }
 
         // Now initialize the Parallel Update Threads
         initParallelThreads();
     }

Here is the call graph for this function:

◆ notifyMobsimAfterSimStep()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimAfterSimStep ( MobsimAfterSimStepEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimAfterSimStepListener.

Definition at line 354 of file WithinDayTravelTime.java.

References org.matsim.api.core.v01.Identifiable< T >.getId(), org.matsim.api.core.v01.network.Link.getLength(), org.matsim.core.mobsim.framework.events.MobsimAfterSimStepEvent< T extends Mobsim >.getSimulationTime(), and org.matsim.withinday.trafficmonitoring.TravelTimeInfoProvider.getTravelTimeInfo().

                                                                     {
         problem = false ;
 
         // yyyy In terms of "bushfire evacuation" design (and maybe even in terms of more general transport telematics)
         // one would need some settable TimeDependentNetworkUpdater class.  kai, dec'17
 
 //      Collection<Link> links = changedLinksByTime.remove(e.getSimulationTime());
         // yyyyyy I find it quite optimistic to do this with doubles. What
         // if someone adds a link change event in between two integer
         // time steps?  kai, dec'17
 
         while( !changedLinksByTime.isEmpty() && changedLinksByTime.firstKey() <= e.getSimulationTime() ) {
             Map<Link, Double> map = changedLinksByTime.pollFirstEntry().getValue();
             for ( Map.Entry<Link,Double> link2speed : map.entrySet() ) {
                 Link link = link2speed.getKey() ;
                 double freeSpeedTravelTime = link.getLength() / link2speed.getValue() ;
                 if ( e.getSimulationTime() > ((QSim)e.getQueueSimulation()).getSimTimer().getSimStartTime() ) {
                     // (otherwise, in some simulations one gets a lot of change events at time 0. kai, dec'17)
                     log.debug("time=" + e.getSimulationTime() +
                                       "; network change event for link=" + link.getId() +
                                       "; new ttime="+ freeSpeedTravelTime );
                 }
                 TravelTimeInfo travelTimeInfo = this.travelTimeInfoProvider.getTravelTimeInfo(link);
                 travelTimeInfo.init(freeSpeedTravelTime);
                 travelTimeInfo.checkActiveState();  // ensure that the estimated link travel time is updated
             }
         }
 
 //      if (links != null) {
 //          for (Link link : links) {
 //              double freeSpeedTravelTime = link.getLength() / link.getFreespeed(e.getSimulationTime());
 //              if ( e.getSimulationTime() > 0 ) {
 //                  log.debug("time=" + e.getSimulationTime() +
 //                                    ";\tnetwork change event for link=" + link.getId() +
 //                                    ";\tnew ttime="+ freeSpeedTravelTime );
 //              }
 //              TravelTimeInfo travelTimeInfo = this.travelTimeInfoProvider.getTravelTimeInfo(link);
 //              travelTimeInfo.init(freeSpeedTravelTime);
 //              travelTimeInfo.checkActiveState();  // ensure that the estimated link travel time is updated
 //          }
 //      }
     }

Here is the call graph for this function:

◆ notifyMobsimBeforeSimStep()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimBeforeSimStep ( MobsimBeforeSimStepEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimBeforeSimStepListener.

Definition at line 399 of file WithinDayTravelTime.java.

References org.matsim.core.mobsim.framework.events.MobsimBeforeSimStepEvent< T extends Mobsim >.getSimulationTime(), org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.printInfo(), and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.run().

                                                                       {
         problem = false ;
 
         now = e.getSimulationTime() ;
 
         // parallel Execution
         this.run(e.getSimulationTime());
 
         printInfo(e.getSimulationTime());
     }

Here is the call graph for this function:

◆ notifyMobsimBeforeCleanup()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimBeforeCleanup ( MobsimBeforeCleanupEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimBeforeCleanupListener.

Definition at line 412 of file WithinDayTravelTime.java.

                                                                       {
         problem = false ;
 
         /*
          * Calling the afterSim Method of the Threads will set their
          * simulationRunning flag to false.
          */
         for (UpdateMeanTravelTimesRunnable runnable : this.updateMeanTravelTimesRunnables) {
             runnable.afterSim();
         }
 
         /*
          * Triggering the startBarrier of the UpdateMeanTravelTimesRunnables.
          * They will check whether the Simulation is still running.
          * It is not, so the Threads will terminate.
          */
         try {
             this.startBarrier.await();
         } catch (InterruptedException | BrokenBarrierException ex) {
             throw new RuntimeException(ex);
         }
     }

◆ printInfo()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.printInfo ( double time )

private

Definition at line 435 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.infoTimeStep, and org.matsim.core.utils.misc.Time.writeTime().

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimBeforeSimStep().

                                         {
         if (time >= this.nextInfoTime) {
             int activeLinks = 0;
             for (UpdateMeanTravelTimesRunnable runnable : this.updateMeanTravelTimesRunnables) {
                 activeLinks += runnable.getActiveLinksCount();
             }
 
             log.info("WithinDayTravelTime at " + Time.writeTime(time) + " #links=" + activeLinks);
 
             this.nextInfoTime += this.infoTimeStep;
         }
     }

Here is the call graph for this function:

◆ run()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.run ( double time )

private

Definition at line 509 of file WithinDayTravelTime.java.

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimBeforeSimStep().

                                   {
 
         try {
             // set current Time
             for (UpdateMeanTravelTimesRunnable updateMeanTravelTimesRunnable : updateMeanTravelTimesRunnables) {
                 updateMeanTravelTimesRunnable.setTime(time);
             }
 
             this.startBarrier.await();
 
             this.endBarrier.await();
         } catch (InterruptedException | BrokenBarrierException e) {
             throw new RuntimeException(e);
         }
     }

◆ initParallelThreads()

void org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.initParallelThreads ( )

private

Definition at line 525 of file WithinDayTravelTime.java.

References org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.numOfThreads, org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.UpdateMeanTravelTimesRunnable.setEndBarrier(), and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.UpdateMeanTravelTimesRunnable.setStartBarrier().

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimInitialized().

                                        {
 
         this.startBarrier = new CyclicBarrier(numOfThreads + 1);
         this.endBarrier = new CyclicBarrier(numOfThreads + 1);
 
         Thread[] threads = new Thread[numOfThreads];
         this.updateMeanTravelTimesRunnables = new UpdateMeanTravelTimesRunnable[numOfThreads];
 
         // setup threads
         for (int i = 0; i < numOfThreads; i++) {
             UpdateMeanTravelTimesRunnable updateMeanTravelTimesRunnable = new UpdateMeanTravelTimesRunnable();
             updateMeanTravelTimesRunnable.setStartBarrier(this.startBarrier);
             updateMeanTravelTimesRunnable.setEndBarrier(this.endBarrier);
             updateMeanTravelTimesRunnables[i] = updateMeanTravelTimesRunnable;
 
             Thread thread = new Thread(updateMeanTravelTimesRunnable);
             thread.setName("UpdateMeanTravelTimes" + i);
             thread.setDaemon(true); // make the Thread demons so they will terminate automatically
             threads[i] = thread;
 
             thread.start();
         }
 
         /*
          * Assign the TravelTimeInfos to the Threads
          */
         int roundRobin = 0;
         for (TravelTimeInfo travelTimeInfo : this.travelTimeInfos.values()) {
             travelTimeInfo.runnable = updateMeanTravelTimesRunnables[roundRobin % numOfThreads];
             roundRobin++;
         }
 
         /*
          * After initialization the Threads are waiting at the endBarrier. We
          * trigger this Barrier once so they wait at the startBarrier what has
          * to be their state when the run() method is called.
          */
         try {
             this.endBarrier.await();
         } catch (InterruptedException | BrokenBarrierException e) {
             throw new RuntimeException(e);
         }
     }

Here is the call graph for this function:

Member Data Documentation

◆ log

final Logger org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.log = LogManager.getLogger(WithinDayTravelTime.class)

staticprivate

Definition at line 92 of file WithinDayTravelTime.java.

◆ network

Network org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.network

private

Definition at line 94 of file WithinDayTravelTime.java.

◆ regularActiveTrips

Map<Id<Vehicle>, TripBin> org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.regularActiveTrips

private

Definition at line 97 of file WithinDayTravelTime.java.

◆ travelTimeInfos

Map<Id<Link>, TravelTimeInfo> org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.travelTimeInfos

private

Definition at line 98 of file WithinDayTravelTime.java.

◆ travelTimeInfoProvider

TravelTimeInfoProvider org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.travelTimeInfoProvider

private

Definition at line 100 of file WithinDayTravelTime.java.

◆ changedLinksByTime

TreeMap<Double, Map<Link,Double> > org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.changedLinksByTime

private

Definition at line 103 of file WithinDayTravelTime.java.

◆ startBarrier

CyclicBarrier org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.startBarrier

private

Definition at line 109 of file WithinDayTravelTime.java.

◆ endBarrier

CyclicBarrier org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.endBarrier

private

Definition at line 110 of file WithinDayTravelTime.java.

◆ updateMeanTravelTimesRunnables

UpdateMeanTravelTimesRunnable [] org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.updateMeanTravelTimesRunnables

private

Definition at line 111 of file WithinDayTravelTime.java.

◆ numOfThreads

final int org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.numOfThreads

private

Definition at line 112 of file WithinDayTravelTime.java.

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.initParallelThreads().

◆ infoTimeStep

final int org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.infoTimeStep = 3600

private

Definition at line 114 of file WithinDayTravelTime.java.

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.notifyMobsimInitialized(), and org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.printInfo().

◆ nextInfoTime

int org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.nextInfoTime = 0

private

Definition at line 115 of file WithinDayTravelTime.java.

◆ vehiclesToFilter

Set<Id<Vehicle> > org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.vehiclesToFilter

private

Definition at line 117 of file WithinDayTravelTime.java.

◆ analyzedModes

final Set<String> org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.analyzedModes

private

Definition at line 118 of file WithinDayTravelTime.java.

Referenced by org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.WithinDayTravelTime().

◆ filterModes

final boolean org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.filterModes

private

Definition at line 119 of file WithinDayTravelTime.java.

◆ problem

boolean org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.problem = true

private

Definition at line 121 of file WithinDayTravelTime.java.

◆ resetCnt

int org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.resetCnt = 0

private

Definition at line 122 of file WithinDayTravelTime.java.

◆ now

double org.matsim.withinday.trafficmonitoring.WithinDayTravelTime.now = Double.NEGATIVE_INFINITY

private

Definition at line 124 of file WithinDayTravelTime.java.

The documentation for this class was generated from the following file:

withinday/trafficmonitoring/WithinDayTravelTime.java

Classes

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ WithinDayTravelTime()

Member Function Documentation

◆ init()

◆ addNetworkChangeEventToLocalDataStructure()

◆ addNetworkChangeEvent()

◆ getLinkTravelTime()

◆ reset()

◆ handleEvent() [1/5]

◆ handleEvent() [2/5]

◆ handleEvent() [3/5]

◆ handleEvent() [4/5]

◆ handleEvent() [5/5]

◆ notifyMobsimInitialized()

◆ notifyMobsimAfterSimStep()

◆ notifyMobsimBeforeSimStep()

◆ notifyMobsimBeforeCleanup()

◆ printInfo()

◆ run()

◆ initParallelThreads()

Member Data Documentation

◆ log

◆ network

◆ regularActiveTrips

◆ travelTimeInfos

◆ travelTimeInfoProvider

◆ changedLinksByTime

◆ startBarrier

◆ endBarrier

◆ updateMeanTravelTimesRunnables

◆ numOfThreads

◆ infoTimeStep

◆ nextInfoTime

◆ vehiclesToFilter

◆ analyzedModes

◆ filterModes

◆ problem

◆ resetCnt

◆ now