在并行流中遇到空对象时添加日志

Question

不确定这里的语法，对 lambda 表达式和排序不熟悉。

            itemStream.parallel().filter(Objects::nonNull).forEach( 
                (item) -> randomMethod(item));

我之前在 for 循环中所做的是检查 null，然后在遇到 null 项时发出警告

                    log.warn("Skipping a null item!");

如何使用基于流的方法在遇到空对象（同时仍在过滤）时进行记录？

Answer 1

随着.filter(Objects::nonNull)您过滤掉所有null元素并只保留非空元素，这意味着forEach您不会收到任何空元素，不用介意记录它。相反，你想要：itemStream.parallel()          .forEach(item -> {                if(Objects.isNull(item)) { ... } else { ... }; // or if(item == null) ...          });