一 定义
流是一个元素的序列，支持串行(单线程)和并行(多线程)的操作。涉及到的类基本都在java.util.stream包下，除了Stream之外，还有元素是基本类型的IntStream、DoubleStream等。
流的基本结构：一个源（数组、集合、I/O等等），零个或者多个中间操作，一个终止操作。其中中间操作就是数据转换，比如map、filter等等，终止操作就是源数据经过数据转换的操作结果，比如count、reduce等。
stream.xxx().yyy().zzz().count();
stream就是源
xxx、yyy、zzz都是中间操作，中间操作的返回值都是Stream,count()就是终止操作
流与集合的区别:
集合的关注点在于更好的存储和访问数据，比如存储数据时选择链表还是树结构存储，而流的意义在于为了理想的结果对数据源执行的聚合操作，比如筛选源数据中符合某条件的元素，对源数据的元素执行转换等等。
二 流的特点
①流本身不存储值，通过管道的方式获取值，因此它对源数据是不修改的。
②流中的参数基本都是代表某一行为的函数式接口，非常适合和Lambda表达式配合。
③流的流的很多操作都是可以Lazy的，如果没终止操作(count)，前面的操作都不执行
三 流的创建
①Stream的静态方法
②根据数组
③根据集合
//静态方法
//of参数为一个可变的参数
Stream<Integer> stream=Stream.of(1,2,3,4,5);
//数组
Integer[] ints={1,2,3,4,5};
//和上面的静态方法创建一样，利用可变参数
Stream<Integer> integerStream=Stream.of(ints);
//利用Arrays的工具方法
Stream<Integer> integerStream1 = Arrays.stream(ints);
//根据集合
List<Integer> list=Arrays.asList(1,2,3,4,5);
Stream<Integer> intStream = list.stream();
四 实例
将数组的元素取平方后求和输出
public class StreamTest {
public static void main(String[] args) {
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
//原来的方式
int sum = 0;
for (int i = 0; i < integerList.size(); i++) {
sum += integerList.get(i) * integerList.get(i);
}
System.out.println(sum);
//使用流的方式
//匿名类
integerList.stream()//构建流
.map(new Function<Integer, Integer>() {
//函数式接口 接受一个参数，返回一个结果
//类型为(int)->{int}
@Override
public Integer apply(Integer integer) {
//integer 为元素
//integer*integer 定义的计算规则 元素平方
return integer*integer;
}
})
.reduce(0, new BinaryOperator<Integer>() {
//函数式接口 接受两个参数，返回一个结果
//类型为(int,int)->int
@Override
public Integer apply(Integer integer, Integer integer2) {
//integer为前面计算的结果 integer2为待计算的元素
//integer+integer2 定义的计算规则 累加
return integer+integer2;
}
});
//lambda表达式
int streamSum = integerList.stream()
.map(it -> it * it)
.reduce(0, Math::addExact);
System.out.println(streamSum);
}
}
五 流的注意点
流已经被操作了或者被关闭了---->异常
System.out.println(stream);
System.out.println(stream.filter());
System.out.println(stream.map());//就是上述的异常
//可以链式调用 但不能上面例子那样调用
