diff --git a/pom.xml b/pom.xml
index c752809..b7397fa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -7,7 +7,7 @@
common-utils
org.warp
- 1.0.3
+ 1.0.4
UTF-8
diff --git a/src/main/java/org/warp/commonutils/batch/ParallelUtils.java b/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
index 3076fa3..74a91f8 100644
--- a/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
+++ b/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
@@ -16,9 +16,15 @@ public class ParallelUtils {
public static void parallelize(Consumer> iterator,
int maxQueueSize,
int parallelism,
- int groupSize,
- BiConsumer consumer) {
- BoundedExecutorService parallelExecutor = BoundedExecutorService.create(maxQueueSize, parallelism, parallelism, 0, TimeUnit.MILLISECONDS, new ShortNamedThreadFactory("ForEachParallel"), (a, b) -> {});
+ int groupSize, BiConsumer consumer) {
+ var parallelExecutor = BoundedExecutorService.create(maxQueueSize,
+ parallelism,
+ parallelism,
+ 0,
+ TimeUnit.MILLISECONDS,
+ new ShortNamedThreadFactory("ForEachParallel"),
+ (a, b) -> {}
+ );
final int CHUNK_SIZE = groupSize;
IntWrapper count = new IntWrapper(CHUNK_SIZE);
VariableWrapper