Application.java

import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.concurrent.ForkJoinPool;
import java.util.stream.IntStream;

public class Application {

    private void processLargeDataSet() {
        List<String> largeDataset = getLargeDataset();
        ForkJoinPool customThreadPool = new ForkJoinPool(5);
        customThreadPool.submit(() -> largeDataset.parallelStream().forEach(System.out::println));
        customThreadPool.shutdownNow();
    }

    private List<String> getLargeDataset() {
        List<String> largeDataset = new ArrayList<>();
        IntStream.range(0, Integer.MAX_VALUE).forEach(i -> {
            largeDataset.add(UUID.randomUUID().toString());
        });
        return largeDataset;
    }
}