从批处理方法调用中收集结果 [重复]

Question

我有以下问题:

我有一个如下的方法，一次只能收集500个名字：

public Optional<ResultDTO> executeRequest(final int time, List<Name> names)

我有一个1000个名字的列表，因此我想使用番石榴将这个列表划分为最大大小为500的子列表

List<List<Name>> nameBatches = Lists.partition(namesList, 500);

并将其传递给请求以获取结果DTO列表。如何在 Java8 中执行此操作？

Answer 1

我不确定java 8中是否提供了类似的功能。当然，你可以在匿名函数中使用foreach，但是它比在java 8中使用List.subList()更难读。

Java 7中的解决方案:

        final Integer sizeOfChunk = 3;
        List<Integer> inputList = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 0);

        //Guava
        List<List<Integer>> firstListOfLists = Lists.partition(inputList, sizeOfChunk);

        //Java 7
        List<List<Integer>> secondListOfLists = new ArrayList<List<Integer>>();
        for (int i=0; i<inputList.size()-sizeOfChunk; i+=sizeOfChunk) {
            secondListOfLists.add(inputList.subList(i, i+sizeOfChunk));
        }
        if (inputList.size() % sizeOfChunk != 0) {
            secondListOfLists.add(inputList.subList(secondListOfLists.size()*sizeOfChunk, inputList.size()));
        }

        System.out.println("Guava: " +  firstListOfLists);
        System.out.println("Java 7: " +  secondListOfLists);

编辑

在您发表评论后，它将是：

List<Optional<ResultDTO>> results = nameBatches .stream().map(l -> executeRequest(something, l)).collect(Collectors.toList()); 

Answer 2

您必须创建一个< code>IntStream来遍历列表中的块，并在单独的映射步骤中创建子列表。

int chunkSize = 500;
int size = namesList.size();
// calc the number of chunks
int chunks = (size - 1) / chunkSize;

List<List<Name>> res = IntStream
    // range over all chunks
    .range(0, chunks + 1)
    // create sub-lists for each chunk
    .mapToObj(
        n -> namesList.subList(n * chunkSize, Math.min(size, (n + 1) * chunkSize)))
    // collect from Stream<List<String>> to List<List<String>>
    .collect(Collectors.toList());

编辑:根据你的评论

我的主要问题是如何为每个名称批次调用执行请求方法并存储结果。

只需添加一个. map（l-