Changeset 5661

Timestamp:

03/10/11 13:15:37 (14 years ago)

Author:

gkronber

Message:

#1418 changed FixedDataAnalysisAlgorithm to start asynchronously (taken from Engine)

File:

• branches/DataAnalysis Refactoring/HeuristicLab.Algorithms.DataAnalysis/3.4/FixedDataAnalysisAlgorithm.cs (modified) (4 diffs)

branches/DataAnalysis Refactoring/HeuristicLab.Algorithms.DataAnalysis/3.4/FixedDataAnalysisAlgorithm.cs

@@ -32 +32 @@
 using System.Collections.Generic;
 using HeuristicLab.Problems.DataAnalysis.Symbolic;
+using System.Threading.Tasks;
+using System.Threading;
 
 namespace HeuristicLab.Algorithms.DataAnalysis {
@@ -55 +57 @@
     }
     #endregion
+    
+    private DateTime lastUpdateTime;
 
     [StorableConstructor]
@@ -75 +79 @@
     public override void Start() {
       base.Start();
+      var cancellationTokenSource = new CancellationTokenSource();
+
       OnStarted();
+      Task task = Task.Factory.StartNew(Run, cancellationTokenSource.Token, cancellationTokenSource.Token);
+      task.ContinueWith(t => {
+        try {
+          t.Wait();
+        }
+        catch (AggregateException ex) {
+          try {
+            ex.Flatten().Handle(x => x is OperationCanceledException);
+          }
+          catch (AggregateException remaining) {
+            if (remaining.InnerExceptions.Count == 1) OnExceptionOccurred(remaining.InnerExceptions[0]);
+            else OnExceptionOccurred(remaining);
+          }
+        }
+        cancellationTokenSource.Dispose();
+        cancellationTokenSource = null;
+        OnStopped();
+      });
+    }
+    private void Run(object state) {
+      CancellationToken cancellationToken = (CancellationToken)state;
+      OnStarted();
+      lastUpdateTime = DateTime.Now;
+      System.Timers.Timer timer = new System.Timers.Timer(250);
+      timer.AutoReset = true;
+      timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);
+      timer.Start();
       try {
         Run();
       }
-      catch (Exception e) {
-        OnExceptionOccurred(e);
+      finally {
+        timer.Elapsed -= new System.Timers.ElapsedEventHandler(timer_Elapsed);
+        timer.Stop();
+        ExecutionTime += DateTime.Now - lastUpdateTime;
       }
-      finally {
-        OnStopped();
-      }
+
+      cancellationToken.ThrowIfCancellationRequested();
     }
-
+    protected abstract void Run();
     #region Events
     protected override void OnProblemChanged() {
@@ -92 +126 @@
       base.OnProblemChanged();
     }
-
+    private void timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e) {
+      System.Timers.Timer timer = (System.Timers.Timer)sender;
+      timer.Enabled = false;
+      DateTime now = DateTime.Now;
+      ExecutionTime += now - lastUpdateTime;
+      lastUpdateTime = now;
+      timer.Enabled = true;
+    }
     #endregion
 
-    protected abstract void Run();
   }
 }