Merge pull request danielgerlag#608 from andrx/master

danielgerlag#607 switched to ConcurrentHashSet.

Author: danielgerlag

src/WorkflowCore/Services/BackgroundTasks/QueueConsumer.cs

@@ -3,6 +3,7 @@
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
+using ConcurrentCollections;
 using Microsoft.Extensions.Logging;
 using WorkflowCore.Interface;
 using WorkflowCore.Models;
@@ -54,7 +55,7 @@ private async void Execute()
         {
             var cancelToken = _cancellationTokenSource.Token;
             var activeTasks = new Dictionary<string, Task>();
-            var secondPasses = new HashSet<string>();
+            var secondPasses = new ConcurrentHashSet<string>();
 
             while (!cancelToken.IsCancellationRequested)
             {
@@ -83,7 +84,7 @@ private async void Execute()
                         continue;
                     }
 
-                    secondPasses.Remove(item);
+                    secondPasses.TryRemove(item);
 
                     var task = new Task(async (object data) =>
                     {
@@ -92,7 +93,7 @@ private async void Execute()
                             await ExecuteItem((string)data);
                             while (EnableSecondPasses && secondPasses.Contains(item))
                             {
-                                secondPasses.Remove(item);
+                                secondPasses.TryRemove(item);
                                 await ExecuteItem((string)data);
                             }
                         }

src/WorkflowCore/WorkflowCore.csproj

@@ -24,6 +24,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="ConcurrentHashSet" Version="1.1.0" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="2.2.0" />
     <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="2.2.0" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="2.2.0" />