java8中Stream的使⽤以及分割list
⼀、Steam的优势
java8中Stream配合Lambda表达式极⼤提⾼了编程效率，代码简洁易懂（可能刚接触的⼈会觉得晦涩难懂），不需要写传统的多线程代码就能写出⾼性能的并发程序
⼆、项⽬中遇到的问题
由于接⼝限制，每次导⼊code只能100个，所以需要分割list。但是由于code数量可能很⼤，这样执⾏效率就会很低。
1.⾸先想到是⽤多线程写传统并⾏程序，但是博主不是很熟练，写出代码可能会出现不可预料的结果，容易出错也难以维护。
2.然后就想到Steam中的parallel，能提⾼性能⼜能利⽤java8的特性，何乐⽽不为。
三、废话不多说，直接先贴代码，然后再解释(java8分割list代码在标题四)。
1.该⽅法是根据传⼊数量⽣成codes,private String getGeneratorCode(int tenantId)是我根据编码规则⽣成唯⼀code这个不需要管，我们要看的是Stream.iterate
2.iterate()第⼀个参数为起始值，第⼆个函数表达式（看⾃⼰想要⽣成什么样的流关键在这⾥），write.blog.csdn/postedit然后必须要通过limit⽅法来限制⾃⼰⽣成的Stream⼤⼩。parallel()是开启并⾏处理。map()就是⼀对⼀的把Stream中的元素映射成ouput Steam中的 元素。最后⽤collect收集，
2.1 构造流的⽅法还有Stream.of()，结合或者数组可直接list.stream();
String[] array = new String[]{"1","2","3"} ;
java stream
stream = Stream.of(array)或者Arrays.Stream(array);
2.2 数值流IntStream
int[] array = new int[]{1,2,3};
IntStream.of(array)或者IntStream.ranage(0,3)
3.以上构造流的⽅法都是已经知道⼤⼩，对于通过⼊参确定的应该图中⽅法⾃⼰⽣成流。
四、java8分割list，利⽤StreamApi实现。
没⽤java8前代码，做个鲜明对⽐():
1.list是我的编码集合（codes）。MAX_SEND为100（即每次100的⼤⼩去分割list）,limit为按编码集合⼤⼩算出的本次需要分割多少次。
2.我们可以看到其实就是多了个skip跟limit⽅法。skip就是舍弃stream前多少个元素，那么limit就是返回流前⾯多少个元素（如果流⾥元素少于该值，则返回全部）。然后开启并⾏处理。通过循环我们的
分割list的⽬标就达到了，每次取到的sendList就是100，100这样⼦的。
3.因为我这⾥业务就只需要到这⾥，如果我们分割之后需要收集之后再做处理，那只需要改写⼀下就ok；如：
List<List<String>> splitList = Stream.iterate(0,n->n+1).limit(limit).parallel().map(a->{
List<String> sendList = list.stream().skip(a*MAX_SEND).limit(MAX_SEND).parallel().List());
}).List());
五、java8流⾥好像拿不到下标，所以我才⽤到构造⼀个递增数列当下标⽤，这就是我⽤java8分割list的过程，⽐以前的for循环看的爽⼼悦⽬，优雅些，性能功也提⾼了。如果各位有更好的实现⽅式，欢迎留⾔指教。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。