Add test for parallel HABS.set(startIndex, endIndex)

(cherry picked from commit de63579984dcf6b9c8965e0468f701e5d75875e8)

Author: s1ck

core/src/test/java/org/neo4j/graphalgo/core/utils/paged/HugeAtomicBitSetTest.java

@@ -23,6 +23,9 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.CsvSource;
 
+import java.util.concurrent.Executors;
+import java.util.concurrent.Phaser;
+
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -81,6 +84,47 @@ void setRange(int startIndex, int endIndex) {
         }
     }
 
+    @Test
+    void setRangeParallel() {
+        var bitSet = HugeAtomicBitSet.create(128, AllocationTracker.EMPTY);
+        var phaser = new Phaser(5);
+        var pool = Executors.newCachedThreadPool();
+        pool.submit(new SetTask(bitSet, phaser, 0, 16));
+        pool.submit(new SetTask(bitSet, phaser, 16, 32));
+        pool.submit(new SetTask(bitSet, phaser, 40, 80));
+        pool.submit(new SetTask(bitSet, phaser, 100, 127));
+        phaser.arriveAndAwaitAdvance();
+        phaser.arriveAndAwaitAdvance();
+
+        for (int i = 0; i < bitSet.capacity(); i++) {
+            if (i >= 0 && i < 32) assertTrue(bitSet.get(i));
+            else if (i >= 40 && i < 80) assertTrue(bitSet.get(i));
+            else if (i >= 100 && i < 127) assertTrue(bitSet.get(i));
+            else assertFalse(bitSet.get(i));
+        }
+    }
+
+    private static final class SetTask implements Runnable {
+        private final HugeAtomicBitSet habs;
+        private final Phaser phaser;
+        private final long startIndex;
+        private final long endIndex;
+
+        private SetTask(HugeAtomicBitSet habs, Phaser phaser, long startIndex, long endIndex) {
+            this.habs = habs;
+            this.phaser = phaser;
+            this.startIndex = startIndex;
+            this.endIndex = endIndex;
+        }
+
+        @Override
+        public void run() {
+            phaser.arriveAndAwaitAdvance();
+            habs.set(startIndex, endIndex);
+            phaser.arrive();
+        }
+    }
+
     @Test
     void testFlipping() {
         var bitSet = HugeAtomicBitSet.create(42, AllocationTracker.EMPTY);