package com.company;

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

import static java.util.Arrays.asList;

/**
 * <p>
 * Создан 07.07.2016
 * <p>
 *
 * @author Евгений Уткин (evgeny.utkin@mediascope.net)
 */
public class A {

    public static void main(String[] args) {
        int batchSize = 2;

        List<Integer> list = asList(1, 2, 3, 4, 5);

        batchedIterator(list, batchSize, System.out::println);
    }

    public static <T> void batchedIterator(List<T> list, int batchSize, Consumer<List<T>> consumer) {
        List<List<T>> result = new ArrayList<>(list.size() / batchSize + 1);
        for (int i = 0; i < list.size(); i = i + batchSize) {
            List<T> ts;
            if (list.size() < i + batchSize) {
                ts = list.subList(i, list.size());
            } else {
                ts = list.subList(i, i + batchSize);
            }
            result.add(ts);
        }
        result.parallelStream().forEach(consumer);
    }
}