source: trunk/CrossPare/src/de/ugoe/cs/cpdp/Runner.java @ 2

package de.ugoe.cs.cpdp;

import java.io.File;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;

import de.ugoe.cs.util.console.Console;
import de.ugoe.cs.util.console.TextConsole;

/**
 * Executable that can be used to run experiments.
 * @author Steffen Herbold
 *
 */
public class Runner {
        
        /**
         * Main class. The arguments are {@link ExperimentConfiguration} files. Each experiment is started in a separate thread. The number of concurrently running threads is the number of logical processors of the host system. 
         * @param args experiment configuration files
         */
        public static void main(String[] args) {
                new TextConsole(Level.FINE);
                
                final int concurrentThreads = Runtime.getRuntime().availableProcessors();
                final ExecutorService threadPool = Executors.newFixedThreadPool(concurrentThreads);
                for( String arg : args ) {
                        File file = new File(arg);
                        if( file.isFile() ) {
                                createConfig(threadPool, file.getAbsolutePath());
                        }
                        else if( file.isDirectory() ) {
                                for( File subfile : file.listFiles() ) {
                                        if( subfile.isFile() ) {
                                                createConfig(threadPool, subfile.getAbsolutePath());
                                        }
                                }
                        }
                }
                threadPool.shutdown();
                try {
                        threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
        }
        
        public static void createConfig(ExecutorService threadPool, String configFile) {
                ExperimentConfiguration config = null;
                try {
                        config = new ExperimentConfiguration(configFile);
                } catch (Exception e) {
                        Console.printerrln("Failure initializing the experiment configuration for configuration file " + configFile);
                        e.printStackTrace();
                }
                if( config!=null ) {
                        Console.trace(Level.FINE, config.toString());
                        Experiment experiment = new Experiment(config);
                        threadPool.execute(experiment);
                }
        }
}