package nl.tudelft.simulation.examples.dsol.terminal;

import java.rmi.RemoteException;

import javax.naming.NamingException;

import nl.tudelft.simulation.dsol.SimRuntimeException;
import nl.tudelft.simulation.dsol.experiment.Replication;
import nl.tudelft.simulation.dsol.experiment.ReplicationMode;
import nl.tudelft.simulation.dsol.simulators.DEVSSimulator;
import nl.tudelft.simulation.dsol.simulators.DEVSSimulatorInterface;
import nl.tudelft.simulation.event.EventInterface;
import nl.tudelft.simulation.event.EventListenerInterface;
import nl.tudelft.simulation.jstats.streams.MersenneTwister;

/**
 * <p>
 * Copyright (c) 2002-2018 Delft University of Technology, Jaffalaan 5, 2628 BX Delft, the Netherlands. All rights reserved. See
 * for project information <a href="https://simulation.tudelft.nl/" target="_blank"> https://simulation.tudelft.nl</a>. The DSOL
 * project is distributed under a three-clause BSD-style license, which can be found at
 * <a href="https://simulation.tudelft.nl/dsol/3.0/license.html" target="_blank">
 * https://simulation.tudelft.nl/dsol/3.0/license.html</a>.
 * </p>
 * @author <a href="https://www.linkedin.com/in/peterhmjacobs">Peter Jacobs</a>
 * @author <a href="https://www.tudelft.nl/averbraeck">Alexander Verbraeck</a>
 */
public final class ExperimentRunnerTerminal implements EventListenerInterface
{
    /** number of running simulations. */
    private int numruns = 0;

    /** number of completed simulations. */
    private int completed = 0;

    /** number of runs. */
    private static final int REPS = 100;

    /** number of runs. */
    private static final int RUNS = 3 * 4 * REPS;

    /**
     * Construct the terminal experiment.
     * @throws SimRuntimeException on error
     * @throws RemoteException on error
     * @throws NamingException on error
     */
    private ExperimentRunnerTerminal() throws SimRuntimeException, RemoteException, NamingException
    {
        long seed = 1;
        int maxConcurrent = 8;
        for (int numQC = 4; numQC <= 6; numQC++)
        {
            for (int numAGV = 25; numAGV <= 28; numAGV++)
            {
                for (int rep = 1; rep <= REPS; rep++)
                {
                    while (this.numruns > maxConcurrent)
                    {
                        try
                        {
                            Thread.sleep(1);
                        }
                        catch (InterruptedException exception)
                        {
                            //
                        }
                    }

                    double runtime = 40 * 60;
                    DEVSSimulator.TimeDouble simulator = new DEVSSimulator.TimeDouble();
                    Terminal model = new Terminal(simulator, rep);
                    Replication.TimeDouble<DEVSSimulatorInterface.TimeDouble> replication =
                            Replication.TimeDouble.create("rep1", 0.0, 0.0, runtime, model);
                    replication.getStreams().put("default", new MersenneTwister(seed++));
                    replication.getTreatment().getProperties().setProperty("numQC", "" + numQC);
                    replication.getTreatment().getProperties().setProperty("numAGV", "" + numAGV);
                    simulator.initialize(replication, ReplicationMode.TERMINATING);
                    model.addListener(this, Terminal.READY_EVENT);
                    this.numruns++;
                    simulator.start();
                    simulator.scheduleEventAbs(runtime - 0.00001, this, this, "terminate",
                            new Object[] {simulator, numQC, numAGV, rep, model});
                }
            }
        }
    }

    /**
     * @param simulator DEVSSimulator.TimeDouble; the simulator
     * @param numQC int; num QC
     * @param numAGV int; num AGV
     * @param rep int; replication number
     * @param model Terminal; the model
     * @throws SimRuntimeException on error
     * @throws RemoteException on error
     */
    public synchronized void terminate(final DEVSSimulator.TimeDouble simulator, final int numQC, final int numAGV,
            final int rep, final Terminal model) throws SimRuntimeException, RemoteException
    {
        simulator.stop();
        System.out.println(numQC + "\t" + numAGV + "\t" + rep + "\tNaN\tNaN\t40\t" + model.getShip().getContainers());
        this.numruns--;
        this.completed++;
        if (this.completed == RUNS)
        {
            System.exit(0);
        }
    }

    /** {@inheritDoc} */
    @Override
    public synchronized void notify(final EventInterface event) throws RemoteException
    {
        if (event.getType().equals(Terminal.READY_EVENT))
        {
            Terminal.Output output = (Terminal.Output) event.getContent();
            System.out.println(output.getNumQC() + "\t" + output.getNumAGV() + "\t" + output.getRep() + "\t"
                    + output.getDelayHours() + "\t" + output.getCosts() + "\t" + output.getReady() + "\t3000");
            this.numruns--;
            this.completed++;
            if (this.completed == RUNS)
            {
                System.exit(0);
            }
        }
    }

    /**
     * @param args String[]; args
     * @throws SimRuntimeException on error
     * @throws RemoteException on error
     * @throws NamingException on error
     */
    public static void main(final String[] args) throws SimRuntimeException, RemoteException, NamingException
    {
        new ExperimentRunnerTerminal();
    }

}