Synchronize progress reporting (#306)

microsoft · Mar 19, 2024 · e70842f · e70842f
1 parent cbdbe25
commit e70842f
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/Sources/Runtime/Test.Psi/PersistenceTest.cs b/Sources/Runtime/Test.Psi/PersistenceTest.cs
@@ -1506,8 +1506,19 @@ public void StoreProgressTest()
                 readStream.Do(_ => Thread.Sleep(5));
                 readStream.Do(_ => Thread.Sleep(10));
 
+                var progressListLock = new object();
+
+                // Capture progress reports
+                var progressReporter = new Progress<double>(x =>
+                {
+                    lock (progressListLock)
+                    {
+                        progress.Add(x);
+                    }
+                });
+
                 // replay as fast as possible from store
-                p2.RunAsync(TimeInterval.Infinite, false, new Progress<double>(x => progress.Add(x)));
+                p2.RunAsync(TimeInterval.Infinite, false, progressReporter);
                 p2.WaitAll();
             }