Changeset 15341 for branches/PushGP/HeuristicLab.PushGP/Push.Thesis/Program.cs

Timestamp:

08/28/17 09:03:34 (7 years ago)

Author:

pkimmesw

Message:

#2665 Testet Problems, Improved Performance

File:

• branches/PushGP/HeuristicLab.PushGP/Push.Thesis/Program.cs (modified) (8 diffs)

branches/PushGP/HeuristicLab.PushGP/Push.Thesis/Program.cs

@@ -3 +3 @@
 
 namespace Push.Thesis {
+  using System.Collections.Generic;
   using System.IO;
+  using System.Threading;
   using System.Threading.Tasks;
 
   using HeuristicLab.Algorithms.GeneticAlgorithm;
   using HeuristicLab.BenchmarkSuite;
+  using HeuristicLab.Clients.Hive;
+  using HeuristicLab.Core;
+  using HeuristicLab.MainForm;
   using HeuristicLab.Optimization;
   using HeuristicLab.ParallelEngine;
   using HeuristicLab.Persistence.Default.Xml;
+  using HeuristicLab.Problems.Instances;
   using HeuristicLab.Problems.ProgramSynthesis.Push.Analyzer;
   using HeuristicLab.Problems.ProgramSynthesis.Push.Crossover;
@@ -18 +24 @@
   using HeuristicLab.Problems.ProgramSynthesis.Push.Problem.BenchmarkSuite;
   using HeuristicLab.Problems.ProgramSynthesis.Push.Selector;
+  using HeuristicLab.SequentialEngine;
 
   class Program {
@@ -23 +30 @@
       //BuildListOfInstructions();
       GenerateRuns();
-      GenerateExperiments();
+      //GenerateExperiments(false);
+      //GenerateHiveHJobs();
       //GenerateExperimentWithAllProblems();
+
+      //var cancellationTokenSource = new CancellationTokenSource();
+      //var progress = UploadHiveJob(new Median(), cancellationTokenSource.Token);
+      //progress.ProgressStateChanged += (sender, a) => {
+      //  if (progress.ProgressState == ProgressState.Finished) {
+      //    Environment.Exit(0);
+      //  }
+      //};
+
+      //Console.ReadKey(false);
     }
 
@@ -54 +72 @@
     }
 
-    static void GenerateExperiments() {
+    static void GenerateExperiments(bool parallel = true) {
       var provider = new BenchmarkSuiteInstanceProvider();
       var descriptors = provider.GetDataDescriptors();
@@ -60 +78 @@
       Parallel.ForEach(descriptors, descriptor => {
         var benchmarkSuiteProblemDescriptor = (BenchmarkSuiteDataDescriptor)descriptor;
-        var alg = GetAlgorithm(benchmarkSuiteProblemDescriptor);
-        var experiment = GetExperiment(alg, 10);
+        var alg = GetAlgorithm(benchmarkSuiteProblemDescriptor, parallel);
+        var experiment = GetExperiment(alg, 50);
 
         XmlGenerator.Serialize(experiment, $@"C:\tmp\Plush - GA\Experiments\Experiment_{descriptor.Name}.hl");
@@ -67 +85 @@
     }
 
+    static IProgress UploadHiveJob(IBenchmarkSuiteDataDescriptor descriptor, CancellationToken token) {
+      var job = GenerateHiveJob(descriptor);
+      HiveClient.StartJob(e => { }, job, token);
+
+      return job.Progress;
+    }
+
+    static IEnumerable<RefreshableJob> GenerateHiveHJobs() {
+      var provider = new BenchmarkSuiteInstanceProvider();
+      var descriptors = provider.GetDataDescriptors();
+      var jobs = descriptors
+        .AsParallel()
+        .Select(GenerateHiveJob);
+
+      return jobs;
+    }
+
+    static RefreshableJob GenerateHiveJob(IDataDescriptor descriptor) {
+      var alg = GetAlgorithm((IBenchmarkSuiteDataDescriptor)descriptor, false);
+      var experiment = GetExperiment(alg, 50);
+      var job = GenerateHiveJob(experiment);
+
+      return job;
+    }
+
+    static RefreshableJob GenerateHiveJob(IOptimizer optimizer) {
+      var hiveTask = ItemTask.GetItemTaskForItem(optimizer);
+      var task = hiveTask.CreateHiveTask();
+      var job = new RefreshableJob {
+        Job =
+          {
+            Name = "[SFL][pkimmesw] - " + optimizer.Name,
+            ResourceNames = "HEAL;Labs"
+          }
+      };
+
+      task.ItemTask.ComputeInParallel = true;
+
+      return job;
+    }
+
     static Experiment GetExperiment(IAlgorithm alg, int repeats) {
-      var experiment = new Experiment("Experiment: " + alg.Problem.Name);
+      var experiment = new Experiment(alg.Problem.Name);
       experiment.Optimizers.Add(new BatchRun {
         Optimizer = alg,
@@ -77 +136 @@
     }
 
-    static IAlgorithm GetAlgorithm(IBenchmarkSuiteDataDescriptor descriptor) {
+    static IAlgorithm GetAlgorithm(IBenchmarkSuiteDataDescriptor descriptor, bool parallel = true) {
       var ga = new GeneticAlgorithm();
 
@@ -128 +187 @@
       }
 
-      ga.Engine = new ParallelEngine();
+      ga.Engine = parallel
+        ? (IEngine)new ParallelEngine()
+        : (IEngine)new SequentialEngine();
 
       return ga;