java8stream的collect三个参数
collect⽅法有两个重载：
第⼀个接收的是Collector类型的，可以直接⽤Collectors这类⼯具传⽅法引⽤。
java stream第⼆个接收的是三个参数的，
supplier：⼀个能创造⽬标类型实例的⽅法。accumulator：⼀个将当元素添加到⽬标中的⽅法。combiner：⼀个将中间状态的多个结果整合到⼀起的⽅法（并发的时候会⽤到）。接着看代码：
Stream stream = Stream.of(1, 2, 3, 4).filter(p -> p > 2);
List result = llect(() -> new ArrayList<>(), (list, item) -> list.add(item), (one, two) -> one.addAll(two));
/* 或者使⽤⽅法引⽤ */
result = llect(ArrayList::new, List::add, List::addAll);
这个例⼦即为过滤⼤于2的元素，将剩余结果收集到⼀个新的list中。
第⼀个函数⽣成⼀个新的ArrayList（最后返回的也是这个）
第⼆个函数的第⼀个参数是前⾯⽣成的ArrayList对象，第⼆个参数是stream中包含的元素，函数体就是把stream中的元素加⼊ArrayList 对象中。第⼆个⽅法被反复调⽤直到原stream的元素被消费完毕；
第三个函数也是接受两个参数，这两个都是ArrayList类型的，第⼀个参数是第⼀个函数创建的list，第⼆个参数，由于在并⾏的时候会创建多个List存储并⾏时各个线程所计算完的结果，没看过源码，我猜测应该是⼀个线程对应⼀个List存储结果，每个线程都会调⽤第⼆个函数进⾏消费当前线程所需要处理的数据，如果创建了N个线程，那么就会有N个结果，然后这些结果就⼀个⼀个传进第三个函数的第⼆个参数。
所以，以原始数据是List为例，stream并⾏的原理难道就是：
⼀、根据collect第⼀个参数创建⼀个List实例(最终得到的也是这个)。
⼀、把stream的原始list数据划分为N块，然后分别交给N个线程。
⼆、每个线程根据⾃⼰得到的那块list数据执⾏相应操作，每个线程⼀开始也是使⽤collect传进来的第⼀个函数创建新的List实例，然后使⽤collect的第⼆个函数消费当前线程需要处理的那⼀块list原始数据，然后得到结果。
三、等所有线程执⾏完毕，得到N个结果（每个结果都是list），此时调⽤N次第三个函数。。第三个函数的第⼀个参数为第⼀步创建的list，第⼆个参数则是各个线程执⾏完毕得到的结果list，并⾏计算时有多少个结果list就执⾏多少次。
四、执⾏完毕后，返回第⼀步创建的list

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