Java8 的一些新特性的学习理解
2015-11-03 10:48
525 查看
近期在学习队列相关的一些知识,在学习过程中发现Iterable<T>接口中新增了两个新的方法,出于好奇,就想知道这是什么东东,干什么用的。俗话说:实践出真知,所以就有了以下反复的测试。
先看下新增的这两个方法:
都知道接口中是不能写实现方法的哈,但是它这却有了实现方法,忽然间觉得世界观都被颠覆了,其实呢这也是java8新增的一个特性,在接口方法中添加default关键字就可以直接在接口中写实现(这不是本文的重点,感兴趣的童鞋可以自行学习java8)。
下面正式开始测试<使用BlockingQueue测试>:
以上输出结果为:
1
2
3
4
5
6
7
8
9
10
-------------------------------------
根据以上结果可以看出,②处并没有输出任何的数据。看下Spliterator提供的迭代类forEachRemaining,它是为了并行处理流而新增的一个迭代类,
源码:
而
根据上面的源码可以看出,action如果为空直接抛出异常。it为空时,it是遍历传入集合的Iterator对象。
所以在①处:调用了迭代调用了tryAdvance,执行完①之后,it已经指向了conllection的最后一项,而对于②处,传入的集合是同一个集合,对于it也已经指向了最后一项,所以返回了false,没有数据可输出。
trySplit:ArrayListSpliterator的trySplit采用二分法,将前一半数据返回, 如果数据太小不能分了,返回null。而ConcurrentLinkedQueue和ConcurrentLinkedDeque的相应的Spliterator处理稍微复杂一点, 第一次取一个,第二个取两个,不超过MAX_BATCH。
更多的功能还需要慢慢的学习。
先看下新增的这两个方法:
default void forEach(Consumer<? super T> action) { Objects.requireNonNull(action); for (T t : this) { action.accept(t); } }
default Spliterator<T> spliterator() { return Spliterators.spliteratorUnknownSize(iterator(), 0); }
都知道接口中是不能写实现方法的哈,但是它这却有了实现方法,忽然间觉得世界观都被颠覆了,其实呢这也是java8新增的一个特性,在接口方法中添加default关键字就可以直接在接口中写实现(这不是本文的重点,感兴趣的童鞋可以自行学习java8)。
下面正式开始测试<使用BlockingQueue测试>:
BlockingQueue<Integer> q = new ArrayBlockingQueue<Integer>(1024); while(q.size()<10){ q.put(q.size()+1); } Spliterator<Integer> split = q.spliterator(); split.forEachRemaining(line->{System.out.println(line);}); //① System.out.println("-------------------------------------"); 8 split.forEachRemaining(line->{System.out.println(line);}); //②
以上输出结果为:
1
2
3
4
5
6
7
8
9
10
-------------------------------------
根据以上结果可以看出,②处并没有输出任何的数据。看下Spliterator提供的迭代类forEachRemaining,它是为了并行处理流而新增的一个迭代类,
源码:
default void forEachRemaining(Consumer<? super T> action) { do { } while (tryAdvance(action)); }
而
tryAdvance方法则对下一个为处理的操作执行action并返回true, 如果没有下一个元素,返回false。
public boolean tryAdvance(Consumer<? super T> action) { if (action == null) throw new NullPointerException(); if (it == null) { it = collection.iterator(); est = (long) collection.size(); } if (it.hasNext()) { action.accept(it.next()); return true; } return false; }
根据上面的源码可以看出,action如果为空直接抛出异常。it为空时,it是遍历传入集合的Iterator对象。
所以在①处:调用了迭代调用了tryAdvance,执行完①之后,it已经指向了conllection的最后一项,而对于②处,传入的集合是同一个集合,对于it也已经指向了最后一项,所以返回了false,没有数据可输出。
trySplit:ArrayListSpliterator的trySplit采用二分法,将前一半数据返回, 如果数据太小不能分了,返回null。而ConcurrentLinkedQueue和ConcurrentLinkedDeque的相应的Spliterator处理稍微复杂一点, 第一次取一个,第二个取两个,不超过MAX_BATCH。
更多的功能还需要慢慢的学习。
相关文章推荐
- java日志处理组件log4j--log4j.xml配置详解
- java中的jar命令与jar包
- Spring-XML配置AOP-案例
- java自定义注解及注解使用
- spring的事务传播属性与数据库的隔离级别
- Android开发之Eclipse中使用git简单步骤
- Java多线程(二)、线程的生命周期和状态控制
- Java 反射机制学习(一)
- spring配置文件
- spring的事务配置
- Java忽略转义字符,原格式输出
- Spring-注解的方式配置AOP-案例
- spring事务管理
- 从”JAVA“而终 6:java数组
- java 项目 学习 资源
- java 实现消费者模型
- JAVA--String和int互相转化
- Leetcode:Subsets 求数组的所有子集
- spring防止不同版本jar包引入
- java+mysql+springmvc get请求乱码