GloryJie

做过类似的，是多个任务有一个满足就提前返回，可以参考下

public static <T> T supplyBatchPredicateTask(List<Callable<T>> taskList, Predicate<T> predicate, long timeout, Executor executor) {
CountDownLatch predicateCountDown = new CountDownLatch(1);
AtomicReference<T> successReference = new AtomicReference<>();
AtomicReference<T> failReference = new AtomicReference<>();

List<CompletableFuture<T>> futureList = new ArrayList<>(taskList.size());

for (Callable<T> task : taskList) {
CompletableFuture<T> future = CompletableFuture.supplyAsync(() -> {
try {
T result = task.call();
if (predicate.test(result)) {
successReference.set(result);
predicateCountDown.countDown();
return result;
}
failReference.set(result);
} catch (Exception exception) {
log.warn("act=supplyBatchPredicateTask 任务执行失败", exception);
}
return null;
}, executor);
futureList.add(future);
}

//全失败(不仅仅是任务失败，还有是断言失败)的情況下进行唤醒
CompletableFuture.allOf(futureList.toArray(new CompletableFuture[] {})).whenComplete((result, throwable) -> {
predicateCountDown.countDown();
});

try {
predicateCountDown.await(timeout, TimeUnit.MILLISECONDS);
} catch (Exception e) {
// ignore
log.warn("act=supplyBatchPredicateTask 等待任务执行结果中断", e);
}
return successReference.get() != null ? successReference.get() : failReference.get();
}

mac 上有个软件 MacFamilyTree 听炫酷的，可以参考下

已领，感谢大佬

在 BFF 层聚合数据的时候用的多，一般会同时调好几个接口。这边使用上线程池一般都托管给 Spring 。
最近在改造成基于 Dag 来编排任务执行了，不过基础还是让线程池执行

在执行 setResponse 之前打印时间 A ，take == null 的时候时间 B 。得出 B < A 的，还没执行前，线程就被唤醒唤醒了。感觉是楼上说的 spuriously 的原因

不建议自己使用 request 对象来解析参数，还有个理由是为了保持方法的一个简单（和 request 对象解耦），和普通方法没什么区别。写单元测试也简单

根据 UA 来拉起对应的手机支付，并不是 PC 的支付接口

换城市的话是不是裸辞好些？ 19 年毕业，现在想从杭州回广东了