Expanded collection tests.

Author: electricessence

testing/Open.Collections.Tests/BasicListTests.cs

@@ -4,7 +4,8 @@
 using Xunit;
 
 namespace Open.Collections.Tests;
-public abstract class BasicListTests<TList> : BasicCollectionTests<TList>
+public abstract class BasicListTests<TList>
+    : BasicCollectionTests<TList>
     where TList : IList<int>
 {
     protected BasicListTests(TList list) : base(list)

testing/Open.Collections.Tests/Collections/LockSyncDictionaryTests.cs

@@ -2,15 +2,15 @@
 
 namespace Open.Collections.Tests.Collections;
 public class LockSyncDictionaryTests
-    : BasicDictionaryTests<LockSynchronizedDictionary<int, int>>
+    : ParallelDictionaryTests<LockSynchronizedDictionary<int, int>>
 {
     public LockSyncDictionaryTests() : base(new())
     {
     }
 }
 
 public class LockSyncOrderedDictionaryTests
-    : BasicDictionaryTests<LockSynchronizedDictionary<int, int>>
+    : ParallelDictionaryTests<LockSynchronizedDictionary<int, int>>
 {
     public LockSyncOrderedDictionaryTests() : base(new())
     {

testing/Open.Collections.Tests/Collections/LockSyncListTests.cs

@@ -2,7 +2,7 @@
 
 namespace Open.Collections.Tests.Collections;
 public class LockSyncListTests
-    : BasicListTests<LockSynchronizedList<int>>
+    : ParallelListTests<LockSynchronizedList<int>>
 {
     public LockSyncListTests() : base(new())
     {

testing/Open.Collections.Tests/Collections/ReadWriteSyncLDictionaryTests.cs

@@ -2,15 +2,15 @@
 
 namespace Open.Collections.Tests.Collections;
 public class ReadWriteSyncDictionaryTests
-    : BasicDictionaryTests<ReadWriteSynchronizedDictionary<int, int>>
+    : ParallelDictionaryTests<ReadWriteSynchronizedDictionary<int, int>>
 {
     public ReadWriteSyncDictionaryTests() : base(new())
     {
     }
 }
 
 public class ReadWriteSyncOrderedDictionaryTests
-    : BasicDictionaryTests<ReadWriteSynchronizedDictionary<int, int>>
+    : ParallelDictionaryTests<ReadWriteSynchronizedDictionary<int, int>>
 {
     public ReadWriteSyncOrderedDictionaryTests() : base(new())
     {

testing/Open.Collections.Tests/Collections/ReadWriteSyncListTests.cs

@@ -2,7 +2,7 @@
 
 namespace Open.Collections.Tests.Collections;
 public class ReadWriteSyncListTests
-    : BasicListTests<ReadWriteSynchronizedList<int>>
+    : ParallelListTests<ReadWriteSynchronizedList<int>>
 {
     public ReadWriteSyncListTests() : base(new())
     {

testing/Open.Collections.Tests/Collections/TrackedDictionaryTests.cs

@@ -4,15 +4,17 @@ namespace Open.Collections.Tests.Collections;
 public class TrackedDictionaryTests
     : BasicDictionaryTests<TrackedDictionary<int, int>>
 {
-    public TrackedDictionaryTests() : base(new())
+    public TrackedDictionaryTests()
+        : base(new (new Threading.ReadWriteModificationSynchronizer()))
     {
     }
 }
 
 public class TrackedOrderedDictionaryTests
     : BasicDictionaryTests<TrackedOrderedDictionary<int, int>>
 {
-    public TrackedOrderedDictionaryTests() : base(new())
+    public TrackedOrderedDictionaryTests()
+        : base(new(new Threading.SimpleLockingModificationSynchronizer()))
     {
     }
 }

testing/Open.Collections.Tests/ParallelDictionaryTests.cs

@@ -0,0 +1,26 @@
+using FluentAssertions;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Xunit;
+
+namespace Open.Collections.Tests;
+public abstract class ParallelDictionaryTests<TDictionary>
+    : BasicDictionaryTests<TDictionary>
+    where TDictionary : IDictionary<int, int>
+{
+    protected ParallelDictionaryTests(TDictionary dictionary) : base(dictionary)
+    {
+    }
+
+    [Fact]
+    public void ParallelAddThenRemove()
+    {
+        const int count = 10000000;
+        Dictionary.Clear();
+        Parallel.For(0, count, i => Dictionary.Add(i, i));
+        Dictionary.Count.Should().Be(count);
+
+        Parallel.For(0, count, i => Dictionary.Remove(i));
+        Dictionary.Count.Should().Be(0);
+    }
+}

testing/Open.Collections.Tests/ParallelListTests.cs

@@ -0,0 +1,27 @@
+using FluentAssertions;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Xunit;
+
+namespace Open.Collections.Tests;
+public abstract class ParallelListTests<TList>
+    : BasicListTests<TList>
+    where TList : IList<int>
+{
+    protected ParallelListTests(TList list) : base(list)
+    {
+    }
+
+    [Fact]
+    public void ParallelAddThenRemove()
+    {
+        const int countAdd = 10000000;
+        Collection.Clear();
+        Parallel.For(0, countAdd, i => Collection.Add(i));
+        Collection.Count.Should().Be(countAdd);
+
+        const int countRemove = 900;
+        Parallel.For(0, countRemove, i => Collection.Remove(i * 3));
+        Collection.Count.Should().Be(countAdd - countRemove);
+    }
+}