#### java8流的操作机制 ##### 特点
- 所有操作是链式调用, 一个元素只迭代一次
- 每一个中间操作返回一个新的流. 流里面有一个属性sourceStage， 指向同一个 地方,就是Head
- Head->nextStage->nextStage->… -> null
- 有状态操作会把无状态操作阶段,单独处理
-
并行环境下, 有状态的中间操作不一定能并行操作.
- parallel/ sequetial 这2个操作也是中间操作(也是返回stream)，但是他们不创建流, 他们只修改 Head的并行标志 ``` import java.util.Random; import java.util.concurrent.TimeUnit; import java.util.stream.Stream;
/**
- 验证stream运行机制
-
- 所有操作是链式调用, 一个元素只迭代一次
-
- 每一个中间操作返回一个新的流. 流里面有一个属性sourceStage
- 指向同一个 地方,就是Head
-
- Head->nextStage->nextStage->… -> null
-
- 有状态操作会把无状态操作阶段,单独处理
-
- 并行环境下, 有状态的中间操作不一定能并行操作.
-
- parallel/ sequetial 这2个操作也是中间操作(也是返回stream)
- 但是他们不创建流, 他们只修改 Head的并行标志
-
* */ public class RunStream {
public static void main(String[] args) { Random random = new Random(); // 随机产生数据 Stream
stream = Stream.generate(() -> random.nextInt()) // 产生500个 ( 无限流需要短路操作. ) .limit(500) // 第1个无状态操作 .peek(s -> print("peek: " + s)) // 第2个无状态操作 .filter(s -> { print("filter: " + s); return s > 1000000; }) // 有状态操作 .sorted((i1, i2) -> { print("排序: " + i1 + ", " + i2); return i1.compareTo(i2); }) // 又一个无状态操作 .peek(s -> { print("peek2: " + s); }).parallel(); // 终止操作 stream.count(); }/**
- 打印日志并sleep 5 毫秒
- @param s */ public static void print(String s) { // System.out.println(s); // 带线程名(测试并行情况) System.out.println(Thread.currentThread().getName() + “ > “ + s); try { TimeUnit.MILLISECONDS.sleep(5); } catch (InterruptedException e) { } }
}
```
