最近處理一個需求，需要將一批數(shù)據(jù)入庫，處理的時候發(fā)現(xiàn)數(shù)據(jù)量超級大，于是就將批數(shù)據(jù)進行分割分批處理。

直接上碼

樣式超贊好看的原文鏈接原文鏈接：jdk8 stream list分割 切割 分批次處理工具類?blog.csdn.net

package com.store.common.utils;

import java.util.*;

import java.util.stream.Collectors;

public class CommonUtil {

/**

* 計算切分次數(shù)

* @param size 需要分割的集合長度

* @param maxNum 集合最大的數(shù)量

* @param

* @return 切分次數(shù)

*/

private static Integer countStep(Integer size, Integer maxNum) {

return (size + maxNum - 1) / maxNum;

}

/**

* 將一個集合進行分割

* @param collections 需要分割的集合 (List LinkedHashSet TreeSet LinkedList)

* @param maxNum 集合最大的數(shù)量

* @param

* @return 分割后的集合

*/

public static Collection> subCollection(Collection collections, int maxNum){

int limit = countStep(collections.size(), maxNum);

//方法一：使用流遍歷操作

// Collection> mglist = new ArrayList<>();

// Stream.iterate(0, n -> n + 1).limit(limit).forEach(i -> {

// mglist.add(collections.stream().skip(i * maxNum).limit(maxNum).collect(Collectors.toList()));

// });

// return mglist;

//方法二：獲取分割后的集合

Collection> splitCollection = Stream.iterate(

0, n -> n + 1).limit(limit).parallel().map(

a -> collections.stream().skip(a * maxNum).limit(maxNum).parallel()

.collect(Collectors.toList())).collect(Collectors.toList());

return splitCollection;

}

public static void main(String[] args) {

//test List

List list = Arrays.asList(1, 2, 3, 4, 5, 6, 7);

//[[1, 2, 3], [4, 5, 6], [7]]

System.out.println(subCollection(list, 3));

//test set , allow LinkedHashSet TreeSet

Set set = new TreeSet() {

{

for (int i = 0; i < 40; i++) {

if (i % 2 == 0) {

add(i);

}

}

}

};

//[[0, 2, 4], [6, 8, 10], [12, 14, 16], [18, 20, 22], [24, 26, 28], [30, 32, 34], [36, 38]]

System.out.println(subCollection(set, 3));

//add()和remove()方法在失敗的時候會拋出異常(不推薦)

Queue queue = new LinkedList();

//添加元素

queue.offer("a");

queue.offer("b");

queue.offer("c");

queue.offer("d");

queue.offer("e");

queue.offer("f");

queue.offer("g");

queue.offer("h");

queue.offer("i");

queue.offer("j");

//[[a, b, c], [d, e, f], [g, h, i], [j]]

System.out.println(subCollection(queue, 3));

}

}

jdk8 stream list分割 切割 分批次處理工具類

————————————————

版權(quán)聲明：本文為CSDN博主「努力奔跑的小蝸牛」的原創(chuàng)文章，遵循CC 4.0 BY-SA版權(quán)協(xié)議，轉(zhuǎn)載請附上原文出處鏈接及本聲明。

總結(jié)

以上是生活随笔為你收集整理的arraylist切割_jdk8 stream list分割 切割 分批次处理工具类的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。