Skip to content

Commit 208883e

Browse files
s1ckknutwalker
andcommitted
Use ParallelUtil.run() in benchmark and test
Co-authored-by: Paul Horn <paul.horn@neotechnology.com>
1 parent 0a707e6 commit 208883e

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

core/src/test/java/org/neo4j/gds/core/utils/paged/HugeAtomicGrowingBitSetTest.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,8 @@
2222
import org.junit.jupiter.params.ParameterizedTest;
2323
import org.junit.jupiter.params.provider.Arguments;
2424
import org.junit.jupiter.params.provider.MethodSource;
25-
import org.neo4j.gds.core.concurrency.RunWithConcurrency;
25+
import org.neo4j.gds.core.concurrency.ParallelUtil;
26+
import org.neo4j.gds.core.concurrency.Pools;
2627
import org.neo4j.gds.core.utils.partition.PartitionUtils;
2728

2829
import java.util.HashSet;
@@ -141,12 +142,7 @@ void testSetParallel(HugeAtomicGrowingBitSet bitSet) {
141142
}
142143
}, Optional.empty());
143144

144-
RunWithConcurrency
145-
.builder()
146-
.tasks(tasks)
147-
.concurrency(concurrency)
148-
.build()
149-
.run();
145+
ParallelUtil.run(tasks, Pools.DEFAULT);
150146

151147
assertThat(bitSet.cardinality()).isEqualTo(nodeCount);
152148
}

0 commit comments

Comments
 (0)