Merge pull request #5011 from brah-mcdude/dev

Update TestScheduler.cs
akkadotnet · May 14, 2021 · 0ef7f07 · 0ef7f07
1 parent 3ebbfcf
commit 0ef7f07
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/core/Akka.TestKit/TestScheduler.cs b/src/core/Akka.TestKit/TestScheduler.cs
@@ -88,10 +88,14 @@ private void InternalSchedule(TimeSpan? initialDelay, TimeSpan delay, ICanTell r
         {
             var scheduledTime = _now.Add(initialDelay ?? delay).UtcTicks;
 
-            if (!_scheduledWork.TryGetValue(scheduledTime, out var tickItems))
+            ConcurrentQueue<ScheduledItem> tickItems;
+            while (!_scheduledWork.TryGetValue(scheduledTime, out tickItems))
             {
                 tickItems = new ConcurrentQueue<ScheduledItem>();
-                _scheduledWork.TryAdd(scheduledTime, tickItems);
+                if (_scheduledWork.TryAdd(scheduledTime, tickItems))
+                {
+                    break;
+                }
             }
 
             var type = message == null ? ScheduledItem.ScheduledItemType.Action : ScheduledItem.ScheduledItemType.Message;