From 56fa4cd0a38aff05fa179daf680cf97a05fae58e Mon Sep 17 00:00:00 2001 From: Markus KARG Date: Thu, 23 May 2024 14:15:11 +0000 Subject: [PATCH] Parallel processing of files --- .../mojo/license/AbstractFileHeaderMojo.java | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/codehaus/mojo/license/AbstractFileHeaderMojo.java b/src/main/java/org/codehaus/mojo/license/AbstractFileHeaderMojo.java index c0ae8ebf2..6fbefd8a0 100644 --- 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 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(); }