threadsafe events collection

dotnet · Nov 9, 2024 · a6e175c · a6e175c
1 parent a88665c
commit a6e175c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/tests/FSharp.Compiler.ComponentTests/CompilerService/AsyncMemoize.fs b/tests/FSharp.Compiler.ComponentTests/CompilerService/AsyncMemoize.fs
@@ -15,14 +15,14 @@ let tap f x = f x; x
 
 let internal record (cache: AsyncMemoize<_,_,_>) =
 
-    let events = ResizeArray()
+    let events = Collections.Concurrent.ConcurrentQueue()
 
     let waitForIdle() = SpinWait.SpinUntil(fun () -> not cache.Updating)
 
     waitForIdle()
     cache.Event
     |> Event.map (fun (e, (_, k, _)) -> e, k)
-    |> Event.add events.Add
+    |> Event.add events.Enqueue
 
     let getEvents () =
         waitForIdle()

diff --git a/tests/FSharp.Compiler.ComponentTests/FSharpChecker/TransparentCompiler.fs b/tests/FSharp.Compiler.ComponentTests/FSharpChecker/TransparentCompiler.fs
@@ -31,7 +31,7 @@ let fileName fileId = $"File%s{fileId}.fs"
 
 let internal recordAllEvents groupBy =
     let mutable cache : AsyncMemoize<_,_,_> option = None
-    let events = ResizeArray()
+    let events = ConcurrentQueue()
 
     let waitForIdle() = SpinWait.SpinUntil(fun () -> not cache.Value.Updating)
 
@@ -40,7 +40,7 @@ let internal recordAllEvents groupBy =
         waitForIdle()
         cache.Value.Event
         |> Event.map (fun (e, k) -> groupBy k, e)
-        |> Event.add events.Add
+        |> Event.add events.Enqueue
 
     let getEvents () =
         waitForIdle()