tutorial.programming.example17Parallelisation.RunParallelisationExample Class Reference

Static Public Member Functions
static void	main (String[] args)

Static Private Attributes
final static Logger	LOG = Logger.getLogger(Math.class)

Detailed Description

Demonstrates how to use parallelisation in MATSim using the Sioux Falls example. It is assumed the machine you are running this on actually accommodates multiple threads.

Author

jwjoubert

Definition at line 59 of file RunParallelisationExample.java.

Member Function Documentation

static void tutorial.programming.example17Parallelisation.RunParallelisationExample.main ( String[]  args )

static

Running the Sioux-Falls scenario, first with single thread, and then in parallel (for all modules allowing parallelisation: mobsim, replanning and events handling).

Note: the purpose of the example is to show how multi-threaded behaviour is switched on. It may be, given your hardware setup, that this example runs longer under the multi-threaded setup ;-)

Parameters

args

Definition at line 73 of file RunParallelisationExample.java.

References org.matsim.core.config.Config.controler, org.matsim.core.config.ConfigUtils.createConfig(), org.matsim.core.utils.io.IOUtils.deleteDirectory(), org.matsim.core.config.Config.global, org.matsim.core.config.ConfigUtils.loadConfig(), org.matsim.core.scenario.ScenarioUtils.loadScenario(), org.matsim.core.config.Config.parallelEventHandling, org.matsim.core.gbl.Gbl.printElapsedTime(), org.matsim.core.config.Config.qsim(), org.matsim.core.controler.Controler.run(), and org.matsim.core.gbl.Gbl.startMeasurement().

                                           {
        /* Running in single thread. */
        Gbl.startMeasurement();
        Config config = ConfigUtils.createConfig();
        String configFilename = "examples/siouxfalls-2014/config_default.xml";
        ConfigUtils.loadConfig(config, configFilename);
        config.controler().setLastIteration(10);
        /*====================================================================*/
        /* Setting parallelisation: */
        config.qsim().setNumberOfThreads(1);                    /* Mobility simulation */
        config.global().setNumberOfThreads(1);                  /* Replanning */
        config.parallelEventHandling().setNumberOfThreads(1);   /* Events handling. */
        /*====================================================================*/
        Scenario sc = ScenarioUtils.loadScenario(config);
        Controler controler = new Controler(sc);
        controler.run();
        LOG.info("Single thread time:");
        Gbl.printElapsedTime();
        
        /* Running multi-threaded. First delete the output directory. */
        IOUtils.deleteDirectory(new File(config.controler().getOutputDirectory()));
        Gbl.startMeasurement();
        config = ConfigUtils.createConfig();
        ConfigUtils.loadConfig(config, configFilename);
        config.controler().setLastIteration(10);
        /*====================================================================*/
        /* Setting parallelisation: */
        config.qsim().setNumberOfThreads(2);                    /* Mobility simulation */
        config.global().setNumberOfThreads(2);                  /* Replanning */
        config.parallelEventHandling().setNumberOfThreads(2);   /* Events handling. */
        /*====================================================================*/
        sc = ScenarioUtils.loadScenario(config);
        controler = new Controler(sc);
        controler.run();
        LOG.info("Multi-threaded time:");
        Gbl.printElapsedTime();
    }

Here is the call graph for this function:

Member Data Documentation

final static Logger tutorial.programming.example17Parallelisation.RunParallelisationExample.LOG = Logger.getLogger(Math.class)

staticprivate

Definition at line 60 of file RunParallelisationExample.java.

---

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

• tutorial/programming/example17Parallelisation/RunParallelisationExample.java