Improved Engine.StartAsync

kbilsted · Oct 25, 2023 · 8cdabed · 8cdabed
1 parent 6b42c77
commit 8cdabed
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/Product/GreenFeetWorkFlow/WorkflowEngine.cs b/src/Product/GreenFeetWorkFlow/WorkflowEngine.cs
@@ -93,10 +93,14 @@ public async Task StartAsync(
         string? engineName = null,
         CancellationToken? stoppingToken = null)
     {
-        await Task.Run(() => Start(configuration, engineName, stoppingToken));
+        Init(configuration, engineName);
+
+        var token = stoppingToken ?? CancellationToken.None;
+
+        var tasks = Workers!.Select(w => w.StartAsync(token));
+        await Task.WhenAll(tasks.ToArray());
     }
 
-
     /// <summary> Start the engine with the current thread as the worker. Also use this if you have trouble debugging weird scenarios </summary>
     public async Task StartAsSingleWorker(
         WorkflowConfiguration configuration,