Changeset 32 for trunk/CrossPare/src/de/ugoe/cs/cpdp/Runner.java

Timestamp:

05/05/15 16:29:40 (9 years ago)

Author:

ftrautsch

Message:

integrating decent into crosspare

File:

• trunk/CrossPare/src/de/ugoe/cs/cpdp/Runner.java (modified) (5 diffs)

trunk/CrossPare/src/de/ugoe/cs/cpdp/Runner.java

@@ -2 +2 @@
 
 import java.io.File;
+import java.lang.reflect.Constructor;
+import java.lang.reflect.InvocationTargetException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -7 +9 @@
 import java.util.logging.Level;
 
+import de.ugoe.cs.cpdp.execution.IExecutionStrategy;
 import de.ugoe.cs.util.console.Console;
 import de.ugoe.cs.util.console.TextConsole;
@@ -23 +26 @@
         public static void main(String[] args) {
                 new TextConsole(Level.FINE);
-                
                 final int concurrentThreads = Runtime.getRuntime().availableProcessors();
                 final ExecutorService threadPool = Executors.newFixedThreadPool(concurrentThreads);
@@ -47 +49 @@
         }
         
+        /**
+         * Creates the config and starts the corresponding experiment
+         * @param threadPool 
+         * @param configFile location of the config file
+         */
         public static void createConfig(ExecutorService threadPool, String configFile) {
                 ExperimentConfiguration config = null;
@@ -55 +62 @@
                         e.printStackTrace();
                 }
+
                 if( config!=null ) {
                         Console.trace(Level.FINE, config.toString());
-                        Experiment experiment = new Experiment(config);
-                        threadPool.execute(experiment);
+                        // Instantiate the class like it was given as parameter in the config file and cast it to the interface
+                        try {
+                                // Because we need to pass a parameter, a normal new Instance call is not possible
+                                Class<?> executionStrategyClass = Class.forName("de.ugoe.cs.cpdp.execution."+config.getExecutionStrategy());
+                                Constructor<?> executionStrategyConstructor = 
+                                                executionStrategyClass.getConstructor(ExperimentConfiguration.class);
+                        
+                                IExecutionStrategy experiment = (IExecutionStrategy) executionStrategyConstructor.newInstance(config);
+                                threadPool.execute(experiment);
+                        } catch (NoSuchMethodException e) {
+                                Console.printerrln("Class \"" + config.getExecutionStrategy()+ "\" does not have the right Constructor");
+                                e.printStackTrace();
+                        } catch (SecurityException e) {
+                                Console.printerrln("Security manager prevents reflection");
+                                e.printStackTrace();
+                        } catch (IllegalArgumentException e) {
+                                Console.printerrln("Class \"" + config.getExecutionStrategy()+ "\" does not have a Constructor, which"
+                                                + "matches the given arguments");
+                                e.printStackTrace();
+                        } catch (InvocationTargetException e) {
+                                Console.printerrln("Constructor in Class \"" + config.getExecutionStrategy()+ "\" is not public");
+                                e.printStackTrace();
+                        } catch (InstantiationException e) {
+                                Console.printerrln("Cannot instantiate Class \"" + config.getExecutionStrategy()+"\"");
+                                e.printStackTrace();
+                        } catch (IllegalAccessException e) {
+                                Console.printerrln("Cannot access Class \"" + config.getExecutionStrategy()+"\"");
+                                e.printStackTrace();
+                        } catch (ClassNotFoundException e) {
+                                Console.printerrln("Class \"" + config.getExecutionStrategy()+ "\" was not found");
+                                e.printStackTrace();
+                        }
+                        
                 }
+                
         }
 }