一、一个例子
package Stream;
import java.util.Optional;
import java.util.stream.Stream;
/**
* 演示并行流和顺序流
*/
public class TaskApp {
public static void main(String[] args) {
/**
* parallel() 开启并行流
*/
Optional<Integer> max= Stream.iterate(1,x->x+1).limit(200).parallel().peek(x->{
System.out.println(Thread.currentThread().getName());
}).max(Integer::compare);
/**
* sequential() 顺序流
*/
Optional<Integer> min= Stream.iterate(1,x->x+1).limit(200).sequential().peek(x->{
System.out.println(Thread.currentThread().getName());
}).max(Integer::compare);
}
}
版权声明:本文为qq_41446768原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。