Skipping next actions when crashing

2020-08-26 16:30:03 +02:00 · 2020-08-26 16:30:03 +02:00 · a6b9037507
commit a6b9037507
parent ad705fe6f9
1 changed files with 1 additions and 0 deletions
--- a/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
+++ b/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
@ -111,6 +111,7 @@ public class ParallelUtils {
 								consumer.accept((K) keysCopy[i], (V) valuesCopy[i]);
 							} catch (Exception ex) {
 								firstExceptionReference.compareAndSet(null, new CompletionException(ex));
+								break;
 							}
 						}
 					});