最后细数一次 JDK8 踩过的坑，往后再不干了

重复的事情不应该再做第二遍，否则是对生命的不尊重。

本文主要内容：JDK8 踩过的坑，内容基础。

??踩坑的原因：未知和遗忘。

本文主要内容

第一类 API：只有特定参数值才会引发异常

第二类 API：只要运行一次就能察觉错误

注：下文内容为上面表格的举例说明。

一、 Collectors.toMap

关于 Collectors.toMap 的易错点主要有两个:

key 计算结果重复

下面案例：模拟数据重复值，toMap 时出现 duplicate key

Map<String, String> map = Arrays.asList("A", "A")
        .stream()
        .collect(Collectors.toMap(str -> str, Function.identity()));

防止脏数据等异常数据，一定指定 mergeFunction；请使用下面 API 进行 toMap

 toMap(Function<? super T, ? extends K> keyMapper,
                                Function<? super T, ? extends U> valueMapper,
                                BinaryOperator<U> mergeFunction) 

值为 null

下面案例：value 值由函数值返回，模拟返回 null， 运行结果 NPE

private static String returnNull() {
    return null;
}
public static void main(String[] args) {
    Map<String, String> map = Arrays.asList("A", "A")
            .stream()
            .collect(Collectors.toMap(str -> str, str -> returnNull(), (first, second) -> first));
}

二、parallelStream

遇到最大的坑：直接将 stream 修改成 parallelStream ， 天真地以为做了性能优化。

常见 stream 流操作中有 DB 查询、远程 API 等耗时操作，直接将 stream 修改成 parallelStream 做优化

并行流

1. ThreadLocal#get 异常
2. 非线程安全类异常

parallelStream 是多线程并行流，容易出现多线程问题

下面案例：相同代码执行两次，结果线程名称不一致。

其他场景不再赘述，一定要知道 parallelStream 是并行的，多线程的问题它都有。特别注意：数据量小不易察觉； 性能优化不能仅仅将 stream 修改成 parallelStream ！！！ 血泪经验......

三、stream#sort

排序字段 null

多字段排序在 tob 业务常见； 常因为第二、三个字段为 null 排序出现 NPE

往事：第一次用这个 API 就出现了线上故障 ≡(▔﹏▔)≡

四、Optional#get/of

get/of

Optional 被引入用来解决 NPE，但下面这两个 API 却容易出现异常

• of 入参为 null 抛 NPE
• get 返回值，检查 value 为 null 抛 NoSuchElementException

下面是 java.util.Optional#get 方法源码

public T get() {
    if (value == null) {
        throw new NoSuchElementException("No value present");
    }
    return value;
}

题外话：Optional 是我个人非常喜欢的一个类，大大减少了 NPE；比如我还用它作出参入参。形如下面：

public <T,R>  Optional<T> function(Optional<R> param) {
    .....
}

五、其他

再啰嗦一下边边角角的 API

stream只能消费一次

运行一次就知道用错误了（好多流的 API 也是只能消费一次）

下面案例：stream 用了多次，出现错误

peek 方法

peek 用的很少，个人不推荐用，初衷为了 debug 。peek 遇到终止类的 API 才执行。

下面案例：convenientMap 并不会插入新的元素。只有添加了一些终止操作才会执行。 例如：collect(Collectors.toList()), forEach等。

// toMap 功能

List<Task> taskList = instTaskBO.getInstanceId(instance.getInstanceId());    
Map<String, Task> convenientMap = new HashMap<>(); 
// 将 list 转成map
taskList.stream().peek(task -> convenientMap.put(String.valueOf(task.getId()), task));

其他

• 8的日期： 不熟，用的少，坑不知道
• CompletableFuture：考虑异常情况；join 设置时长

下面案例：对于异常给一个默认的返回值

// 异常情况给一个默认值
private CompletableFuture<Integer> calculate(Supplier<Integer> supplier) {
    return CompletableFuture
            .supplyAsync(() -> invokeTask(supplier))
            .exceptionally(throwable -> {
                log.error(".....", throwable);
                return 0;
            });
}

六、最后总结

本文总结个人在使用 JDK8 踩过的坑，内容基础。但总结是比较花费精力，后面尽量总结研究一些高级点的东西~~

有更多想法的小伙伴，欢迎在评论区留言交流