Java CompletableFuture 流式编程最佳实践？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1557 天前的主题，其中的信息可能已经有所发展或是发生改变。

虽然在很多地方看到有人说 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 的正确姿势吗，或者关于函数式编程比较好的教程

重试

string

thenrun

任务

18 条回复 • 2020-12-24 16:06:34 +08:00

yamasa

2020-09-22 11:58:58 +08:00

1.想学 FP，java 是很不适合的语言。要真正理解思想应该考虑学下 Lisp 的一些方言。反正国内这环境你也指望不了这些语言吃饭，就当是修炼内功了。
2.实在要在 java 里面搞，上 reactor 啊，比 cf 那一套残次品真的完成度高太多了，只要业务是真的 async 的，可以做到一把梭哈完。