Codes

[siddharthrgade21-a11y]

import java.util.List;
import java.util.concurrent.ForkJoinPool;
import java.util.stream.IntStream;

public class AdvancedStream {
public static void main(String[] args) {
List data = IntStream.rangeClosed(1, 100).boxed().toList();

    // Using a custom pool to control parallelism
    ForkJoinPool customPool = new ForkJoinPool(4);
    try {
        customPool.submit(() ->
            data.parallelStream().forEach(i -> {
                System.out.println(Thread.currentThread().getName() + " processing: " + i);
            })
        ).get();
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        customPool.shutdown();
    }
}

}