Merge remote-tracking branch 'origin/master' into improve_mutation_of…

…_directives
stryker-mutator · Nov 22, 2024 · f5bbfd9 · f5bbfd9
2 parents da24233 + f7c0a71
commit f5bbfd9
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 10 deletions.
diff --git a/src/Stryker.Core/Stryker.Core.UnitTest/Mutants/CsharpMutantOrchestratorTests.cs b/src/Stryker.Core/Stryker.Core.UnitTest/Mutants/CsharpMutantOrchestratorTests.cs
@@ -1953,11 +1953,13 @@ public void ShouldProtectDirectives()
 }";
         var expected = @"public void SomeMethod() {if(StrykerNamespace.MutantControl.IsActive(0)){}else{
     var x = 0;
-if(StrykerNamespace.MutantControl.IsActive(1)){;}else{if(StrykerNamespace.MutantControl.IsActive(2)){    #if !DEBUG
+#if !DEBUG
+if(StrykerNamespace.MutantControl.IsActive(1)){;}else{if(StrykerNamespace.MutantControl.IsActive(2)){
     x--;
-}else{    #if !DEBUG
+}else{
     x++;
-}}    #endif
+}}
+#endif
 }}";
 
         ShouldMutateSourceInClassToExpected(source, expected);

diff --git a/src/Stryker.Core/Stryker.Core/Initialisation/InputFileResolver.cs b/src/Stryker.Core/Stryker.Core/Initialisation/InputFileResolver.cs
@@ -542,20 +542,20 @@ private static StringBuilder BuildReferenceChoice(IEnumerable<string> projectRef
 
     private sealed class DynamicEnumerableQueue<T>
     {
-        private readonly Queue<T> _queue;
-        private readonly HashSet<T> _cache;
+        private readonly ConcurrentQueue<T> _queue;
+        private readonly ConcurrentDictionary<T, bool> _cache;
 
         public DynamicEnumerableQueue(IEnumerable<T> init)
         {
-            _cache = [.. init];
-            _queue = new Queue<T>(_cache);
+            _cache = new(init.ToDictionary(x => x, x => true));
+            _queue = new (_cache.Keys);
         }
 
-        public bool Empty => _queue.Count == 0;
+        public bool Empty => _queue.IsEmpty;
 
         public void Add(T entry)
         {
-            if (!_cache.Add(entry))
+            if (!_cache.TryAdd(entry, true))
             {
                 return;
             }
@@ -566,7 +566,10 @@ public IEnumerable<T> Consume()
         {
             while (_queue.Count > 0)
             {
-                yield return _queue.Dequeue();
+                if (_queue.TryDequeue(out var entry))
+                {
+                    yield return entry;
+                }
             }
         }
     }