Parallel processing of files

mojohaus · May 23, 2024 · 56fa4cd · 56fa4cd
1 parent b253d99
commit 56fa4cd
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/src/main/java/org/codehaus/mojo/license/AbstractFileHeaderMojo.java b/src/main/java/org/codehaus/mojo/license/AbstractFileHeaderMojo.java
@@ -24,6 +24,7 @@
 
 import java.io.File;
 import java.io.IOException;
+import java.io.UncheckedIOException;
 import java.nio.file.Files;
 import java.nio.file.StandardCopyOption;
 import java.util.Collections;
@@ -635,8 +636,16 @@ private void processCommentStyle(String commentStyle, List<File> filesToTreat) t
         FileHeaderTransformer transformer = getTransformer(transformers, commentStyle);
         FileHeaderProcessor processor = getFileHeaderProcessor(license, transformer);
 
-        for (File file : filesToTreat) {
-            processFile(processor, file);
+        try {
+            filesToTreat.parallelStream().forEach(file -> {
+                try {
+                    processFile(processor, file);
+                } catch (IOException e) {
+                    throw new UncheckedIOException(e);
+                }
+            });
+        } catch (UncheckedIOException e) {
+            throw e.getCause();
         }
         filesToTreat.clear();
     }