headwayGenerator =
new HeadwayGenerator(getStreamInformation(), new Frequency(800, FrequencyUnit.PER_HOUR));
LaneBasedGTUCharacteristicsGenerator characteristicsGenerator = new CharacteristicsGenerator(this.simulator,
new double[] {0.9, 0.06, 0.04}, this.network, getStreamInformation());
RoomChecker roomChecker = new TTCRoomChecker(new Duration(10.0, DurationUnit.SI));
LaneBasedGTUGenerator gen = new LaneBasedGTUGenerator(id, headwayGenerator, characteristicsGenerator,
GeneratorPositions.create(initialLongitudinalPositions, stream), this.network, this.simulator, roomChecker,
new IdGenerator(""));
gen.setInstantaneousLaneChange(true);
}
/** {@inheritDoc} */
@Override
public Serializable getSourceId()
{
return "BusStreetModel";
}
}
/**
*
* Copyright (c) 2013-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved.
*
* BSD-style license. See OpenTrafficSim License.
*
* @version $Revision$, $LastChangedDate$, by $Author$, initial version 29 jan. 2017
* @author Alexander Verbraeck
* @author Peter Knoppers
* @author Wouter Schakel
*/
private static class HeadwayGenerator implements Generator
{
/** Demand level. */
private final Frequency demand;
/** the streams. */
private final StreamInformation streamInformation;
/**
* @param streamInformation StreamInformation; the random streams
* @param demand Frequency; demand
*/
HeadwayGenerator(final StreamInformation streamInformation, final Frequency demand)
{
this.streamInformation = streamInformation;
this.demand = demand;
}
/** {@inheritDoc} */
@Override
public Duration draw() throws ProbabilityException, ParameterException
{
return new Duration(-Math.log(this.streamInformation.getStream("generation").nextDouble()) / this.demand.si,
DurationUnit.SI);
}
}
/**
*
* Copyright (c) 2013-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved.
*
* BSD-style license. See OpenTrafficSim License.
*
* @version $Revision$, $LastChangedDate$, by $Author$, initial version 29 jan. 2017
* @author Alexander Verbraeck
* @author Peter Knoppers
* @author Wouter Schakel
*/
public static class CharacteristicsGenerator implements LaneBasedGTUCharacteristicsGenerator
{
/** Simulator. */
private final DEVSSimulatorInterface.TimeDoubleUnit simulator;
/** Probabilities. */
private final double[] probabilities;
/** Strategical planner factory. */
private final LaneBasedStrategicalPlannerFactory plannerFactory;
/** Route for car. */
private final Route carRouteN;
/** Route for car. */
private final Route carRouteO;
/** Nodes for bus, line 1. */
private final List busNodes1;
/** Nodes for bus, line 2. */
private final List busNodes2;
/** Short dwell time. */
private final Duration shortDwellTime = new Duration(15.0, DurationUnit.SI);
/** Long dwell time. */
private final Duration longDwellTime = new Duration(60.0, DurationUnit.SI);
/** The network. */
private OTSRoadNetwork network;
/** the random streams. */
private final StreamInformation streamInformation;
/**
* @param simulator DEVSSimulatorInterface.TimeDoubleUnit; simulator
* @param probabilities double[]; probabilities
* @param network OTSRoadNetwork; network
* @param streamInformation the random streams
*/
public CharacteristicsGenerator(final DEVSSimulatorInterface.TimeDoubleUnit simulator, final double[] probabilities,
final OTSRoadNetwork network, final StreamInformation streamInformation)
{
this.simulator = simulator;
this.probabilities = probabilities;
this.network = network;
this.streamInformation = streamInformation;
List carNodesN = new ArrayList<>();
carNodesN.add(network.getNode("A"));
carNodesN.add(network.getNode("B"));
carNodesN.add(network.getNode("C"));
carNodesN.add(network.getNode("D"));
carNodesN.add(network.getNode("E"));
carNodesN.add(network.getNode("F"));
carNodesN.add(network.getNode("G"));
carNodesN.add(network.getNode("H"));
carNodesN.add(network.getNode("I"));
carNodesN.add(network.getNode("J"));
carNodesN.add(network.getNode("K"));
carNodesN.add(network.getNode("L"));
carNodesN.add(network.getNode("M"));
List carNodesO = new ArrayList<>(carNodesN);
carNodesN.add(network.getNode("N"));
carNodesO.add(network.getNode("O"));
this.carRouteN = new Route("carN", carNodesN);
this.carRouteO = new Route("carO", carNodesO);
this.busNodes1 = new ArrayList<>();
this.busNodes1.add(network.getNode("A"));
this.busNodes1.add(network.getNode("B"));
this.busNodes1.add(network.getNode("B1"));
this.busNodes1.add(network.getNode("B2"));
this.busNodes1.add(network.getNode("D"));
this.busNodes1.add(network.getNode("E"));
this.busNodes1.add(network.getNode("F"));
this.busNodes1.add(network.getNode("G"));
this.busNodes1.add(network.getNode("H"));
this.busNodes1.add(network.getNode("I"));
this.busNodes1.add(network.getNode("I1"));
this.busNodes1.add(network.getNode("I2"));
this.busNodes1.add(network.getNode("J"));
this.busNodes1.add(network.getNode("K"));
this.busNodes1.add(network.getNode("K1"));
this.busNodes1.add(network.getNode("K2"));
this.busNodes1.add(network.getNode("L"));
this.busNodes1.add(network.getNode("M"));
this.busNodes1.add(network.getNode("N"));
this.busNodes2 = new ArrayList<>();
this.busNodes2.add(network.getNode("A"));
this.busNodes2.add(network.getNode("B"));
this.busNodes2.add(network.getNode("C"));
this.busNodes2.add(network.getNode("C1"));
this.busNodes2.add(network.getNode("C2"));
this.busNodes2.add(network.getNode("E"));
this.busNodes2.add(network.getNode("F"));
this.busNodes2.add(network.getNode("G"));
this.busNodes2.add(network.getNode("H"));
this.busNodes2.add(network.getNode("I"));
this.busNodes2.add(network.getNode("J"));
this.busNodes2.add(network.getNode("K"));
this.busNodes2.add(network.getNode("K1"));
this.busNodes2.add(network.getNode("K2"));
this.busNodes2.add(network.getNode("K3"));
this.busNodes2.add(network.getNode("L"));
this.busNodes2.add(network.getNode("M"));
this.busNodes2.add(network.getNode("O"));
this.plannerFactory =
new LaneBasedStrategicalRoutePlannerFactory(new LMRSFactoryCarBus(), new ParameterFactoryCarBus());
}
/** {@inheritDoc} */
@Override
public LaneBasedGTUCharacteristics draw() throws ProbabilityException, ParameterException, GTUException
{
double r = this.streamInformation.getStream("generation").nextDouble();
int classNum = r < this.probabilities[0] ? 0 : r < this.probabilities[0] + this.probabilities[1] ? 1 : 2;
r = this.streamInformation.getStream("generation").nextDouble();
GTUType gtuType;
Length length;
Length width;
Speed maximumSpeed;
Route route;
switch (classNum)
{
case 0:
{
gtuType = new GTUType("CAR", this.network.getGtuType(GTUType.DEFAULTS.CAR));
length = new Length(4.0, LengthUnit.SI);
width = new Length(1.8, LengthUnit.SI);
maximumSpeed = new Speed(200.0, SpeedUnit.KM_PER_HOUR);
route = r < 0.5 ? this.carRouteN : this.carRouteO;
break;
}
case 1:
{
gtuType = new GTUType("BUS1", this.network.getGtuType(GTUType.DEFAULTS.SCHEDULED_BUS));
length = new Length(8.0, LengthUnit.SI);
width = new Length(2.0, LengthUnit.SI);
maximumSpeed = new Speed(100.0, SpeedUnit.KM_PER_HOUR);
BusSchedule schedule = new BusSchedule("bus1." + this.simulator.getSimulatorTime(), this.busNodes1, "1");
Time now = this.simulator.getSimulatorTime();
schedule.addBusStop("Cafe Boszicht.1", now.plus(new Duration(70.0, DurationUnit.SI)), this.longDwellTime,
true);
schedule.addBusStop("Herberg De Deugd", now.plus(new Duration(100.0, DurationUnit.SI)), this.shortDwellTime,
false);
schedule.addBusStop("De Vleeshoeve", now.plus(new Duration(120.0, DurationUnit.SI)), this.shortDwellTime,
false);
schedule.addBusStop("Dorpshuys", now.plus(new Duration(200.0, DurationUnit.SI)), this.longDwellTime, true);
schedule.addBusStop("De verkeerde afslag", now.plus(new Duration(270.0, DurationUnit.SI)),
this.longDwellTime, true);
route = schedule;
break;
}
case 2:
{
gtuType = new GTUType("BUS2", this.network.getGtuType(GTUType.DEFAULTS.SCHEDULED_BUS));
length = new Length(12.0, LengthUnit.SI);
width = new Length(2.0, LengthUnit.SI);
maximumSpeed = new Speed(100.0, SpeedUnit.KM_PER_HOUR);
BusSchedule schedule = new BusSchedule("bus2." + this.simulator.getSimulatorTime(), this.busNodes2, "2");
Time now = this.simulator.getSimulatorTime();
schedule.addBusStop("Cafe Boszicht.2", now.plus(new Duration(80.0, DurationUnit.SI)), this.longDwellTime,
true);
schedule.addBusStop("De Vleeshoeve", now.plus(new Duration(110.0, DurationUnit.SI)), this.shortDwellTime,
false);
schedule.addBusStop("Kippenboerderij De Scharrelaar", now.plus(new Duration(180.0, DurationUnit.SI)),
this.longDwellTime, false);
schedule.addBusStop("De verkeerde afslag", now.plus(new Duration(260.0, DurationUnit.SI)),
this.longDwellTime, true);
route = schedule;
break;
}
default:
throw new RuntimeException("Reaching default of switch case.");
}
GTUCharacteristics gtuCharacteristics = new GTUCharacteristics(gtuType, length, width, maximumSpeed,
Acceleration.instantiateSI(3.0), Acceleration.instantiateSI(-8.0), length.times(0.5));
return new LaneBasedGTUCharacteristics(gtuCharacteristics, this.plannerFactory, route, null, null,
VehicleModel.MINMAX);
}
}
/**
*
* Copyright (c) 2013-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved.
*
* BSD-style license. See OpenTrafficSim License.
*
* @version $Revision$, $LastChangedDate$, by $Author$, initial version 29 jan. 2017
* @author Alexander Verbraeck
* @author Peter Knoppers
* @author Wouter Schakel
*/
private static class LMRSFactoryCarBus implements LaneBasedTacticalPlannerFactory
{
/** */
LMRSFactoryCarBus()
{
}
/** {@inheritDoc} */
@Override
public final Parameters getParameters()
{
ParameterSet parameters = new ParameterSet();
parameters.setDefaultParameters(ParameterTypes.class);
parameters.setDefaultParameters(LmrsParameters.class);
parameters.setDefaultParameters(ConflictUtil.class);
parameters.setDefaultParameters(AbstractIDM.class);
return parameters;
}
/** {@inheritDoc} */
@Override
public final LMRS create(final LaneBasedGTU gtu) throws GTUException
{
DefaultLMRSPerceptionFactory pFac = new DefaultLMRSPerceptionFactory();
LMRS lmrs = new LMRS(new IDMPlus(), gtu, pFac.generatePerception(gtu), Synchronization.PASSIVE, Cooperation.PASSIVE,
GapAcceptance.INFORMED, Tailgating.NONE);
lmrs.setDefaultIncentives();
if (gtu.getGTUType().isOfType(GTUType.DEFAULTS.SCHEDULED_BUS))
{
lmrs.addMandatoryIncentive(new IncentiveBusStop());
lmrs.addAccelerationIncentive(new AccelerationBusStop());
lmrs.getPerception().addPerceptionCategory(new DirectBusStopPerception(lmrs.getPerception()));
}
return lmrs;
}
}
/**
*
* Copyright (c) 2013-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved.
*
* BSD-style license. See OpenTrafficSim License.
*
* @version $Revision$, $LastChangedDate$, by $Author$, initial version 29 jan. 2017
* @author Alexander Verbraeck
* @author Peter Knoppers
* @author Wouter Schakel
*/
private static class ParameterFactoryCarBus implements ParameterFactory
{
/** */
ParameterFactoryCarBus()
{
}
/** {@inheritDoc} */
@Override
public void setValues(final Parameters parameters, final GTUType gtuType) throws ParameterException
{
parameters.setParameter(ParameterTypes.LOOKAHEAD, new Length(100.0, LengthUnit.METER));
if (gtuType.isOfType(GTUType.DEFAULTS.CAR))
{
parameters.setParameter(LmrsParameters.VGAIN, new Speed(3.0, SpeedUnit.METER_PER_SECOND));
}
else if (gtuType.isOfType(GTUType.DEFAULTS.SCHEDULED_BUS))
{
parameters.setParameter(ParameterTypes.A, new Acceleration(0.8, AccelerationUnit.METER_PER_SECOND_2));
}
else
{
throw new RuntimeException("Unable to determine characteristics for GTU of type " + gtuType);
}
}
}
}