Changeset 6024 for branches/HeuristicLab.MetaOptimization

Timestamp:

04/18/11 23:27:42 (14 years ago)

Author:

cneumuel

Message:

#1215

• improved the way AlgorithmExecutor handles cancellation

Location:

branches/HeuristicLab.MetaOptimization

Files:

• HeuristicLab.MetaOptimization.Test/Program.cs (modified) (4 diffs)
• HeuristicLab.Problems.MetaOptimization/3.3/AlgorithmExecutor.cs (modified) (3 diffs)
• HeuristicLab.Problems.MetaOptimization/3.3/Evaluators/AlgorithmEvaluator.cs (modified) (1 diff)

branches/HeuristicLab.MetaOptimization/HeuristicLab.MetaOptimization.Test/Program.cs

@@ -48 +48 @@
 
     private static int metaAlgorithmPopulationSize = 10;
-    private static int metaAlgorithmMaxGenerations = 10;
+    private static int metaAlgorithmMaxGenerations = 20;
     private static int metaProblemRepetitions = 2;
-    private static int baseAlgorithmMaxGenerations = 10;
+    private static int baseAlgorithmMaxGenerations = 50;
     private static double mutationProbability = 0.10;
 
@@ -80 +80 @@
       MetaOptimizationProblem metaOptimizationProblem = new MetaOptimizationProblem();
       metaOptimizationProblem.Repetitions = new IntValue(metaProblemRepetitions);
-      GeneticAlgorithm metaLevelAlgorithm = GetMetaGA(metaOptimizationProblem);
-      //GeneticAlgorithm metaLevelAlgorithm = GetParallelMetaGA(metaOptimizationProblem);
+      //GeneticAlgorithm metaLevelAlgorithm = GetMetaGA(metaOptimizationProblem);
+      GeneticAlgorithm metaLevelAlgorithm = GetParallelMetaGA(metaOptimizationProblem);
       //GeneticAlgorithm metaLevelAlgorithm = GetHiveParallelMetaGA(metaOptimizationProblem);
 
@@ -353 +353 @@
         tasks[i] = new Task<TimeSpan>((alg) => {
           Console.WriteLine("Task {0} started.", Task.CurrentId);
+          var cancellationTokenSource = new CancellationTokenSource();
 
           Stopwatch swx = new Stopwatch();
           swx.Start();
           ((EngineAlgorithm)alg).ExecutionTimeChanged += new EventHandler(Program_ExecutionTimeChanged);
-          ((EngineAlgorithm)alg).StartSync();
+          ((EngineAlgorithm)alg).StartSync(cancellationTokenSource.Token);
           ((EngineAlgorithm)alg).ExecutionTimeChanged -= new EventHandler(Program_ExecutionTimeChanged);
           swx.Stop();
@@ -467 +468 @@
         algs.Enqueue(clonedGa);
 
+        var cancellationTokenSource = new CancellationTokenSource();
         //if (algs.Count > 24)
         //  algs.Dequeue();
-        clonedGa.StartSync();
+        clonedGa.StartSync(cancellationTokenSource.Token);
         sw.Stop();
         latestExecutionTimes.Enqueue(sw.Elapsed);

branches/HeuristicLab.MetaOptimization/HeuristicLab.Problems.MetaOptimization/3.3/AlgorithmExecutor.cs

@@ -6 +6 @@
 
   public static class AlgorithmExtensions {
-    public static void StartSync(this IAlgorithm algorithm) {
-      var executor = new AlgorithmExecutor(algorithm);
-      executor.StartSync();
-    }
     public static void StartSync(this IAlgorithm algorithm, CancellationToken cancellationToken) {
       var executor = new AlgorithmExecutor(algorithm, cancellationToken);
@@ -23 +19 @@
     private AutoResetEvent waitHandle = new AutoResetEvent(false);
     private CancellationToken cancellationToken;
-    private bool useCancellationToken = false;
-
-    public AlgorithmExecutor(IAlgorithm algorithm) {
-      this.algorithm = algorithm;
-    }
 
     public AlgorithmExecutor(IAlgorithm algorithm, CancellationToken cancellationToken) {
       this.algorithm = algorithm;
       this.cancellationToken = cancellationToken;
-      this.useCancellationToken = true;
     }
 
@@ -38 +28 @@
       algorithm.Stopped += new EventHandler(algorithm_Stopped);
       algorithm.Paused += new EventHandler(algorithm_Paused);
-      
-      if(useCancellationToken && algorithm is EngineAlgorithm && ((EngineAlgorithm)algorithm).Engine is SequentialEngine.SequentialEngine) {
-        ((SequentialEngine.SequentialEngine)((EngineAlgorithm)algorithm).Engine).Start(cancellationToken);
-      } else {
+
+      using (CancellationTokenRegistration registration = cancellationToken.Register(new Action(cancellationToken_Canceled))) {
         algorithm.Start();
+        waitHandle.WaitOne();
+        waitHandle.Dispose();
       }
 
-      waitHandle.WaitOne();
-      waitHandle.Dispose();
       algorithm.Stopped -= new EventHandler(algorithm_Stopped);
       algorithm.Paused -= new EventHandler(algorithm_Paused);
+      if (algorithm.ExecutionState == Core.ExecutionState.Started) {
+        algorithm.Pause();
+      }
+      cancellationToken.ThrowIfCancellationRequested();
     }
 
-    void algorithm_Paused(object sender, EventArgs e) {
+    private void algorithm_Paused(object sender, EventArgs e) {
       waitHandle.Set();
     }
 
-    void algorithm_Stopped(object sender, EventArgs e) {
+    private void algorithm_Stopped(object sender, EventArgs e) {
+      waitHandle.Set();
+    }
+
+    private void cancellationToken_Canceled() {
       waitHandle.Set();
     }

branches/HeuristicLab.MetaOptimization/HeuristicLab.Problems.MetaOptimization/3.3/Evaluators/AlgorithmEvaluator.cs

@@ -64 +64 @@
       var sw = new Stopwatch();
       sw.Start();
+      //// prepare and clear is needed, if the algorithm has been started and stopped before (this happens when meta level algorithm is paused)
+      //algorithm.Prepare(); // <--- SHOULD NOT HAPPEN!
+      //algorithm.Runs.Clear();
+
       algorithm.StartSync(CancellationToken);
       sw.Stop();