ParallelCollectors.parallelForEach()

[pivovarit]

Adds ParallelCollectors.parallelForEach() - a fire-and-forget collector for parallel side-effecting operations that returns CompletableFuture<Void> instead of collecting results.

This fills a gap in the API for common use cases like sending notifications, writing to external systems, or updating caches in parallel - where callers care about completion but not about return values.

Three overloads following established conventions:

// Default - Virtual Threads, unbounded parallelism
stream.collect(parallelForEach(i -> sendNotification(i)));

// Configurable - custom executor, parallelism, batching, decorators
stream.collect(parallelForEach(i -> sendNotification(i), c -> c
    .executor(executor)
    .parallelism(64)
    .batching()
));

// Convenience - just a parallelism cap
stream.collect(parallelForEach(i -> sendNotification(i), 64));

[sonarqubecloud]

Quality Gate passed

Issues
3 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud