RunFlexibleQNetworkFactoryExample.java

Go to the documentation of this file.

/* *********************************************************************** *
 * project: org.matsim.*                                                   *
 *                                                                         *
 * *********************************************************************** *
 *                                                                         *
 * copyright       : (C) 2008 by the members listed in the COPYING,        *
 *                   LICENSE and WARRANTY file.                            *
 * email           : info at matsim dot org                                *
 *                                                                         *
 * *********************************************************************** *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *   See also COPYING, LICENSE and WARRANTY file                           *
 *                                                                         *
 * *********************************************************************** */
package org.matsim.core.mobsim.qsim.qnetsimengine;

import jakarta.inject.Inject;

import org.matsim.api.core.v01.Scenario;
import org.matsim.api.core.v01.network.Link;
import org.matsim.api.core.v01.network.Network;
import org.matsim.api.core.v01.network.Node;
import org.matsim.core.api.experimental.events.EventsManager;
import org.matsim.core.config.Config;
import org.matsim.core.config.ConfigUtils;
import org.matsim.core.config.groups.QSimConfigGroup;
import org.matsim.core.controler.AbstractModule;
import org.matsim.core.controler.Controler;
import org.matsim.core.mobsim.framework.MobsimTimer;
import org.matsim.core.mobsim.qsim.interfaces.AgentCounter;
import org.matsim.core.mobsim.qsim.qnetsimengine.QNetsimEngineI.NetsimInternalInterface;
import org.matsim.core.scenario.ScenarioUtils;
import org.matsim.vis.snapshotwriters.SnapshotLinkWidthCalculator;

public class RunFlexibleQNetworkFactoryExample {

    static final class MyQNetworkFactory implements QNetworkFactory {
        @Inject private EventsManager events ;
        @Inject private Scenario scenario ; // yyyyyy I would like to get rid of this. kai, mar'16
        @Inject private Network network ;
        @Inject private QSimConfigGroup qsimConfig ;

        private NetsimEngineContext context;
        private NetsimInternalInterface netsimEngine;

        @Override
        public final void initializeFactory( AgentCounter agentCounter, MobsimTimer mobsimTimer, NetsimInternalInterface netsimEngine1 ) {
            double effectiveCellSize = ((Network)network).getEffectiveCellSize() ;

            SnapshotLinkWidthCalculator linkWidthCalculator = new SnapshotLinkWidthCalculator();
            linkWidthCalculator.setLinkWidthForVis( qsimConfig.getLinkWidthForVis() );
            if (! Double.isNaN(network.getEffectiveLaneWidth())){
                linkWidthCalculator.setLaneWidth( network.getEffectiveLaneWidth() );
            }
            AbstractAgentSnapshotInfoBuilder snapshotBuilder = QNetsimEngineWithThreadpool.createAgentSnapshotInfoBuilder( scenario, linkWidthCalculator );

            this.context = new NetsimEngineContext(events, effectiveCellSize, agentCounter, snapshotBuilder, qsimConfig, mobsimTimer, linkWidthCalculator ) ;

            this.netsimEngine = netsimEngine1 ;
        }
        @Override
        public final QNodeI createNetsimNode( Node node ) {
            QNodeImpl.Builder builder = new QNodeImpl.Builder( netsimEngine, context, qsimConfig ) ;
            return builder.build( node ) ;

        }
        @Override
        public final QLinkI createNetsimLink( Link link, QNodeI queueNode ) {

            QLinkImpl.Builder linkBuilder = new QLinkImpl.Builder(context, netsimEngine) ;
            {
                QueueWithBuffer.Builder laneBuilder = new QueueWithBuffer.Builder( context );
                linkBuilder.setLaneFactory( laneBuilder );
            }
            return linkBuilder.build(link, queueNode) ;
        }
    }

    public static void main(String[] args) {
        Config config = ConfigUtils.createConfig() ;

        Scenario scenario = ScenarioUtils.createScenario( config ) ;

        Controler controler = new Controler( scenario ) ;

        controler.addOverridingModule( new AbstractModule(){
            @Override public void install() {
                bind( QNetworkFactory.class ).to( MyQNetworkFactory.class ) ;
            }
        });

        controler.run();

    }

}