Java CompletableFuture 流式编程最佳实践？

• 虽然在很多地方看到有人说 java8 里的 CompletableFuture 是个残品，忍不住还是想在项目中用用，然后就碰到几个很蛋疼的问题

重试

• 在 CompletableFuture 里调 rest 接口，发现没有自带的重试机制，比如根据响应码重试，根据 exception 类型重试，根据特定的响应内容重试。。。
• 解决：引入第三方框架Failsafe，目前跟 CompletableFuture 搭配使用感觉还不错，需要的功能都有了

任务顺序

• 有时候想在一个任务处阻塞住，等其他任务完成；有时候需要多个任务并发完成。目前没办法在一条流式语句中完成所有任务，需要拆成多个 CompletableFuture，再进行组合
  • “一条流式任务”指类似这种

  CompletableFuture.supplyAsync(...)
  	.thenCompose(...)
    .thenApply(...)
    .thenRun(...)
    .thenxxx(...)
    .whenComplete((v, ex) -> ...);
  

• 用.thenCompose(v -> CompletableFuture.supplyAsync(() -> doWork(v), executor))时任务会停下等 doWork 完成，用.thenRun(() -> doWork2())的时候不会。。。
  • 这个地方应该是我理解还不够，没有理清楚 thenCompose 、thenCombine 、thenAccept 、thenRun 、thenApply 中哪些是能够“阻塞”的，哪些是不能的

一条流式语句中目前没解决的问题

whenComplete

• 在一条流式语句中完成所有任务就不用写多个 whenComplete，把所有任务中出现的异常都能放到一个 whenComplete 统一处理。

需要多个参数参与任务流转的问题

String doWork1(){}

Integer doWork2(String work1Result){}

String finalWork(String work1Result, Integer work2Result){}

CompletableFuture.supplyAsync(doWork1)
  	.thenCompose(doWork2)
    .thenRun(someWork) //someWork 中并不需要 work1 和 work2 的结果
    .thenCompose(finalWork)

• 但是为了能够将 work1 和 work2 的结果传递到 finalWork，就必须要在 someWork 中强行加上入参，再原样放到返回中

• 解决：所有方法一律入参 tuple，返回 tuple，方法中只取需要的值，其他值放在 tuple 中往后流转。但是方法显得不够模块，很冗余，而且对后面维护代码的人很不友好

  • vavr框架中的 tuple2 tuple3...（通过 map1 、update1 ）或者 either 还是比较好用的，弥补了一部分原生 java 的缺陷

• 感觉最近对函数式编程、函子这些比较入迷，有大佬能推荐一下 java8 中使用 CompletableFuture 的正确姿势吗，或者关于函数式编程比较好的教程