/* Copyright (C) 2013-2020 TU Dortmund
 * This file is part of LearnLib, http://www.learnlib.de/.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package de.learnlib.examples.parallelism;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Random;

import de.learnlib.api.SUL;
import de.learnlib.api.oracle.MembershipOracle;
import de.learnlib.api.oracle.MembershipOracle.MealyMembershipOracle;
import de.learnlib.api.oracle.parallelism.ParallelOracle;
import de.learnlib.api.query.DefaultQuery;
import de.learnlib.driver.util.MealySimulatorSUL;
import de.learnlib.oracle.membership.SULOracle;
import de.learnlib.oracle.membership.SimulatorOracle.MealySimulatorOracle;
import de.learnlib.oracle.parallelism.ParallelOracleBuilders;
import net.automatalib.automata.transducers.impl.compact.CompactMealy;
import net.automatalib.commons.util.collections.CollectionsUtil;
import net.automatalib.util.automata.random.RandomAutomata;
import net.automatalib.words.Alphabet;
import net.automatalib.words.Word;
import net.automatalib.words.impl.Alphabets;

/**
 * An example for creating {@link ParallelOracle}s using the {@link ParallelOracleBuilders} factory.
 *
 * @author frohme
 */
@SuppressWarnings("PMD.SystemPrintln")
public class ParallelismExample1 {

    private static final int AUTOMATON_SIZE = 100;
    private static final int QUERIES_EXP = 6;

    private final CompactMealy<Integer, Character> automaton;
    private final SUL<Integer, Character> automatonAsSUL;

    private final Collection<DefaultQuery<Integer, Word<Character>>> queries;

    public ParallelismExample1() {
        final Alphabet<Integer> inputs = Alphabets.integers(0, 9);
        final Alphabet<Character> outputs = Alphabets.characters('a', 'z');
        this.automaton = RandomAutomata.randomMealy(new Random(0), AUTOMATON_SIZE, inputs, outputs);
        this.automatonAsSUL = new MealySimulatorSUL<>(automaton);

        System.out.println("Generating queries");

        // generate 1 million (10^6) input words
        this.queries = new ArrayList<>((int) Math.pow(inputs.size(), QUERIES_EXP));
        for (List<Integer> input : CollectionsUtil.allTuples(inputs, QUERIES_EXP)) {
            queries.add(new DefaultQuery<>(Word.fromList(input)));
        }
    }

    public static void main(String[] args) {
        ParallelismExample1 example = new ParallelismExample1();

        example.runSequentialOracles();
        example.runParallelOracles();
    }

    private void runSequentialOracles() {
        final MealyMembershipOracle<Integer, Character> sequenceSULOracle = new SULOracle<>(automatonAsSUL);
        final MealySimulatorOracle<Integer, Character> sequentialMQOracle = new MealySimulatorOracle<>(automaton);

        System.out.println("Sequential SUL oracle");
        answerQueries(sequenceSULOracle);

        System.out.println("Sequential MQ oracle");
        answerQueries(sequentialMQOracle);
    }

    private void runParallelOracles() {

        // we want to limit the number of parallel threads to the number of available cores
        final int availableProcessors = Runtime.getRuntime().availableProcessors();

        final ParallelOracle<Integer, Word<Character>> parallelSULOracle =
                ParallelOracleBuilders.newStaticParallelOracle(this.automatonAsSUL)
                                      .withNumInstances(availableProcessors)
                                      .create();

        final MealySimulatorOracle<Integer, Character> oracle = new MealySimulatorOracle<>(this.automaton);
        // MealySimulatorOracle is thread-safe
        final ParallelOracle<Integer, Word<Character>> parallelMQOracle =
                ParallelOracleBuilders.newStaticParallelOracle(() -> oracle)
                                      .withNumInstances(availableProcessors)
                                      .create();

        System.out.println("Parallel SUL oracle");
        answerQueries(parallelSULOracle);

        System.out.println("Parallel MQ oracle");
        answerQueries(parallelMQOracle);

        parallelSULOracle.shutdownNow();
        parallelMQOracle.shutdownNow();
    }

    private void answerQueries(MembershipOracle<Integer, Word<Character>> oracle) {
        long t0 = System.currentTimeMillis();
        oracle.processQueries(queries);
        long t1 = System.currentTimeMillis();

        System.out.println("  Answering queries took " + (t1 - t0) + "ms");
    }

}
