Collectors.toMap 本身不支持动态过滤，需先用 Stream.filter() 筛选未过期的 Key 再收集；若存在重复 ID，须指定 merge 函数避免异常；禁止在 mapper 中返回 null 或用 Optional 试图跳过，应恪守 filter 负责筛选、toMap 负责映射的职责分离原则。

使用 Collectors.toMap 时无法直接在收集过程中“动态过滤”元素——它本身不支持跳过条目。但你可以把过滤逻辑前置，结合 Stream.filter() 实现“只对未过期的 Key 对象建映射”。关键在于：先筛，再转 Map。

判断 Key 是否过期是前提

假设你的 Key 是自定义对象（如 CacheKey），它有 isExpired() 或 getExpiryTime() 方法：

• 确保该类能可靠判断是否过期（例如对比当前时间与 TTL）
• 避免在 toMap 的 keyMapper/valueMapper 中做耗时或副作用操作

用 filter + toMap 组合完成“动态过滤”效果

这是最常用、最清晰的做法：

List<CacheKey> keys = ...;
Map<String, CacheValue> validMap = keys.stream()
    .filter(key -> !key.isExpired())                    // 先剔除过期项
    .collect(Collectors.toMap(
        CacheKey::getId,                               // key mapper
        key -> lookupValue(key)                        // value mapper，可按需查值
    ));

注意：如果存在重复 ID，toMap 会抛 IllegalStateException。需要去重或指定 merge 函数：

• 保留第一个：(v1, v2) -> v1
• 取最新值：(v1, v2) -> v2
• 或改用 Collectors.groupingBy + 后续处理

避免在 mapper 中隐式过滤（不推荐）

有人尝试在 keyMapper 返回 null 来“跳过”，但 toMap 会直接抛 NullPointerException；也有用 Optional 包装再 flatMap，反而让逻辑变重、可读性下降。这不是设计意图，也不安全。

批量校验 + 并行流需注意线程安全

若 isExpired() 依赖共享状态（如全局时钟、缓存版本），且你用了 parallelStream()，要确认该方法是无状态、线程安全的。否则建议用普通 stream，或加锁/使用原子时钟（如 System.nanoTime() 配合相对 TTL）。

本质上，“动态过滤过期 Key”不是 toMap 的职责，而是 Stream 流水线中 filter 的任务。理清职责边界，代码更健壮、易测、易维护。