applyToEither本质是竞速选择而非合并结果:谁先完成(无论成功或异常)即用其结果执行后续函数,不等待、不兜底、不校验;需手动在任务内或Function中做有效性判断与降级。

applyToEither 本质是“竞速选择”,不是“合并结果”
applyToEither 的核心语义是:两个 CompletionStage 并发执行,**谁先完成(无论成功或异常),就用它的结果走后续函数**。它不等另一个,也不做兜底重试,更不会合并、过滤或判空 —— 这些都得你手动加逻辑。
常见误解是以为它能自动跳过 null 或异常响应,实际不是:applyToEither 碰到第一个完成的 stage,哪怕它返回 null 或抛出 NullPointerException,也会立刻传给你的 Function。所以别指望它“智能选有效值”。
典型错误现象:
- 调用百度地图和高德地图接口,一个返回
null,一个返回正常坐标,但最终拿到的是null,前端报坐标缺失 - Redis 缓存未命中时快速返回
null,DB 查询慢但结果正确,却因applyToEither选了前者导致数据丢失
怎么安全地用 applyToEither 做渠道优选
关键不在 applyToEither 本身,而在你封装的异步任务和后续处理函数。必须把“有效性判断”提前到 stage 内部,或者在 Function 中拦截无效值并主动降级。
推荐做法:
- 每个渠道任务内部做基础校验,无效结果统一包装成
Optional.empty()或抛出特定异常(如ChannelUnavailableException) - 在
applyToEither的Function参数里,先检查输入是否可接受;不可接受时,**不返回,而是主动触发 fallback 逻辑(比如调用.join()等另一个)** - 避免在
Function里做耗时操作或阻塞调用,否则会拖慢整个竞速流程
示例(简化版):
CompletableFuture<Coordinate> baidu = CompletableFuture.supplyAsync(() -> {
Coordinate c = callBaiduApi();
return c != null && c.isValid() ? c : null; // 显式返回 null 表示无效
});
CompletableFuture<Coordinate> amap = CompletableFuture.supplyAsync(() -> {
Coordinate c = callAmapApi();
return c != null && c.isValid() ? c : null;
});
Coordinate result = baidu.applyToEither(amap, coord -> {
if (coord != null) return coord;
// 当前 coord 是 null,说明这个渠道失效了 → 转向另一个
return amap.join(); // 注意:这里会阻塞,仅适合低频/兜底场景
}).join();
线程池隔离是性能与稳定性的前提
如果你把 Redis 查询和 DB 查询都扔进 ForkJoinPool.commonPool(),一旦 DB 查询因慢 SQL 占满线程,Redis 查询也会被卡住 —— 竞速就变成“一起慢”。applyToEither 失去意义。
必须为不同渠道配置独立线程池:
- IO 密集型渠道(HTTP 调用、DB、Redis):用
Executors.newCachedThreadPool()或带队列的ThreadPoolExecutor,避免默认的ForkJoinPool守护线程被拖垮 - 不要复用同一个
Executor给响应时间差异大的渠道,否则快渠道会被慢渠道“带节奏” - 线程池拒绝策略建议用
CallerRunsPolicy,让调用方自己执行,比直接丢弃请求更可控
exceptionally 和 handle 的分工要清楚
applyToEither 自身不捕获异常 —— 如果任一 stage 抛异常,它会原样透出,除非你显式加 exceptionally 或 handle。
区别在于:
-
exceptionally只在当前 stage 异常完成时触发,且只能返回同类型值,适合简单兜底(如返回默认坐标) -
handle无论正常还是异常都会触发,参数是(result, throwable),适合做统一日志、指标打点、或根据异常类型走不同 fallback - 别在
exceptionally里调join()另一个 stage —— 它可能还在跑,造成隐式同步等待,破坏竞速本意
applyToEither 的竞速边界只到第一个 stage 完成为止,它不管那个结果有没有业务意义**。有效性判断、降级路径、线程资源隔离,这三件事不做实,再多的“先到先得”也只是把问题从慢变成了错。

















