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 的正确姿势吗,或者关于函数式编程比较好的教程

相关文章

15 thoughts on “Java CompletableFuture 流式编程最佳实践?

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

  2. CompletableFuture/CompletableStage 感觉适合作为最终输出的类型使用,中间过程用 RxJava 之类的 Reactive Stream 类库更合适

  3. @jelipo 考虑其他同事的学习成本,公司项目上 kotlin 可能性不大,只能先熟悉函数式编程练一下内功

发表评论

电子邮件地址不会被公开。 必填项已用*标注