本文介绍如何利用 supplier 和 stream 的惰性求值特性，在 java stream 中延迟执行高开销方法（如数据库查询或远程调用），仅当上游数据未命中时才触发，避免不必要的性能损耗。
在使用 Java Stream 处理数据流时，若需“先查本地缓存，未命中再调用昂贵方法获取补充数据”，关键在于确保昂贵操作不被提前执行。常见误区是直接将 expensive().stream() 传入 Stream.concat() —— 此时 expensive() 会在流构建阶段立即调用，违背了“按需执行”的初衷。
✅ 正确解法：用 Supplier 封装，实现真正懒加载
核心思想是：不直接传递 List<MyObject>，而是传递 Supplier<List<MyObject>>。Supplier.get() 仅在 flatMap 实际消费该 supplier 时才被调用，从而实现真正的惰性求值。
以下是推荐的简洁、可读性强的单行式实现：
public static Optional<MyObject> findTarget(String input, List<MyObject> myList) {
return Stream.<Supplier<List<MyObject>>>of(
() -> myList,
() -> expensive())
.flatMap(supplier -> supplier.get().stream())
.filter(o -> o.hasName(input))
.findFirst();
}? 注意类型推导：Stream.<Supplier<List<MyObject>>>of(...) 显式指定了泛型，避免编译器因 lambda 类型模糊导致推断失败（尤其在较旧 JDK 版本中）。
? 运行效果验证
配合如下测试代码：
立即学习“Java免费学习笔记（深入）”；
record MyObject(String s) {
public boolean hasName(String in) { return s.equals(in); }
}
static List<MyObject> expensive() {
System.out.println("expensive() called"); // 仅在需要时打印
return List.of(new MyObject("z"));
}
public static void main(String[] args) {
List<MyObject> myList = List.of(new MyObject("a"));
System.out.println("case 1 (hit): " + findTarget("a", myList)); // 不打印 expensive()
System.out.println("case 2 (miss): " + findTarget("x", myList)); // 打印 expensive()
}输出为：
case 1 (hit): Optional[MyObject[s=a]] case 2 (miss): expensive() called Optional.empty
✅ 完全符合预期：expensive() 仅在 myList 无匹配项时才被调用。
⚠️ 注意事项与最佳实践
- 不要滥用 Stream.concat 替代懒加载：Stream.concat(a, b) 会立即求值 b（若 b 是 expensive().stream()），因其参数是 Stream 而非 Supplier<Stream>。
- 优先使用 Stream.of(...).flatMap(...) 模式：它天然支持 Supplier 链式组合，语义清晰且线程安全（Supplier 本身无状态）。
- 若需更多层级（如三级 fallback），只需扩展 Stream.of() 中的 Supplier 列表，例如 .of(() -> cache, () -> dbQuery, () -> apiCall)，仍保持统一结构。
- 避免副作用陷阱：确保 expensive() 方法自身是幂等的——虽然只调用一次，但若逻辑含状态变更，需额外评估一致性风险。
✅ 总结
通过将数据源封装为 Supplier<List<T>> 并结合 Stream.of(...).flatMap(s -> s.get().stream())，我们以极简、函数式的方式实现了「短路式多源查找」，兼顾可读性、性能与 Java Stream 的惰性契约。这比手动拆分为两步 findFirst().or(...) 更优雅，也彻底消除了重复的过滤逻辑，是处理条件性数据加载场景的推荐范式。
