Changeset 13349 for branches/Async/HeuristicLab.DebugEngine

Timestamp:

11/23/15 21:18:26 (9 years ago)

Author:

jkarder

Message:

#2258: added StartAsync to IExecutable

File:

• branches/Async/HeuristicLab.DebugEngine/3.3/DebugEngine.cs (modified) (1 diff)

branches/Async/HeuristicLab.DebugEngine/3.3/DebugEngine.cs

@@ -174 +174 @@
     }
 
-    public override void Start() {
-      base.Start();
+    public override async Task StartAsync(CancellationToken cancellationToken) {
+      await base.StartAsync(cancellationToken);
       cancellationTokenSource = new CancellationTokenSource();
       stopPending = false;
-      Task task = Task.Factory.StartNew(Run, cancellationTokenSource.Token, cancellationTokenSource.Token);
-      task.ContinueWith(t => {
-        try {
-          t.Wait();
-        }
-        catch (AggregateException ex) {
+      using (var cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationTokenSource.Token, cancellationToken)) {
+        Task task = Task.Factory.StartNew(Run, cts.Token, cts.Token);
+        await task.ContinueWith(t => {
           try {
-            ex.Flatten().Handle(x => x is OperationCanceledException);
+            t.Wait();
           }
-          catch (AggregateException remaining) {
-            if (remaining.InnerExceptions.Count == 1) OnExceptionOccurred(remaining.InnerExceptions[0]);
-            else OnExceptionOccurred(remaining);
+          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;
-
-        if (stopPending) ExecutionStack.Clear();
-        if (stopPending || !CanContinue) OnStopped();
-        else OnPaused();
-      });
+          cancellationTokenSource.Dispose();
+          cancellationTokenSource = null;
+
+          if (stopPending) ExecutionStack.Clear();
+          if (stopPending || !CanContinue) OnStopped();
+          else OnPaused();
+        });
+      }
     }