CompletableFuture抄作业

清疚 2023-07-13 15:12 16阅读 0赞

### 文章目录 ###

*  前言
 *  总结图
 *  代码走起
 *   *  应用
 *  最后
 *  总结

# 前言 #

为啥叫抄作业？因为看着别人的博客自己总结，算是抄作业吧，哈哈~

*  [编程老司机带你玩转 CompletableFuture 异步编程][CompletableFuture]

3y跟敖丙都挺强的，蘑菇街的人才，虽然上面那一篇不是他写的，但是总结得很好。

# 总结图 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70]  
  摘自文章中！

# 代码走起 #

import org.springframework.boot.test.context.SpringBootTest;
    
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ExecutionException;
    
    @SpringBootTest
    class DemoApplicationTests {
    
        public static void main(String[] args) throws ExecutionException, InterruptedException {
    
            CompletableFuture<String> a = CompletableFuture.supplyAsync(() -> {
                sleep(5000);
                System.out.println("划水");
                return "划水";
            });
    
            /*CompletableFuture<String> b = CompletableFuture.supplyAsync(() -> {
                sleep(2000);
                System.out.println("带薪拉屎");
                return "带薪拉屎";
            });*/
    
            /*CompletableFuture<String> c = CompletableFuture.supplyAsync(() -> {
                sleep(1000);
                System.out.println("学习");
                return "学习";
            });*/
    
            /*CompletableFuture.anyOf(a, b, c)
                    .whenComplete((t, action) -> CompletableFuture.runAsync(() -> {
                        System.out.println("关机一天工资到手");
                    }));*/
    
           /* CompletableFuture.allOf(a, b, c)
                    .whenComplete((t, action) -> CompletableFuture.runAsync(() -> {
                        System.out.println("关机一天工资到手");
                    }));*/
    
    
            /*a.thenCompose(result -> CompletableFuture.supplyAsync(() -> {
                sleep(2000);
                System.out.println("带薪拉屎");
                return "带薪拉屎";
            })).join();*/
    
            a.applyToEither(CompletableFuture.supplyAsync(() -> {
                sleep(2000);
                System.out.println("带薪拉屎");
                return "带薪拉屎";
            }),s->s).join();
    
        }
    
        private static void sleep(int i) {
            try {
                Thread.sleep(i);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    
    }

<table> 
 <thead> 
  <tr> 
   <th>关系</th> 
   <th>方法名</th> 
   <th>注意点</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>直接运行</td> 
   <td>supplyAsync有返回值，runAsync没有返回值</td> 
   <td>使用get()获取，包括异常也可以打印出来</td> 
  </tr> 
  <tr> 
   <td>串行</td> 
   <td>thenApply</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>and关系</td> 
   <td>thenCompose</td> 
   <td>在主线程加上join()来等待结果</td> 
  </tr> 
  <tr> 
   <td>所有执行完再执行</td> 
   <td>allOf</td> 
   <td>返回值为null，可以在后面加上whenComplete执行完毕操作</td> 
  </tr> 
  <tr> 
   <td>or关系</td> 
   <td>applyToEither</td> 
   <td>看下上面的demo基本就是哪个执行快，就执行哪个，只执行一个</td> 
  </tr> 
  <tr> 
   <td>所有任务只执行任意一个</td> 
   <td>anyOf</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>异常处理</td> 
   <td>handler，或者exceptionally</td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

## 应用 ##

曾经有个功能是下载之后进行压缩的，然后我就用了这个，经常没有等到其他任务执行完就结束了。我后来用get方法等到有结果再结束。

如果学习了上面这些，我会用allOf来实现全部完成之后的操作~

# 最后 #

执行下代码里面的allOf:

学习
    带薪拉屎
    划水
    关机一天工资到手

# 总结 #

一直喊着all in。我们的生活不只有工作，在认真工作之后快乐生活，不断学习，从而提高工作效率，创造更多价值。坚持变优秀,跟你一起成长的大鸡腿

[CompletableFuture]: https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247486805&idx=3&sn=b3b7d29f69e9e2a20c90695cf811f43b&chksm=ebd74c54dca0c542e480b35e651fff1acd9acc3a79134966f2165829b4d27f4541db9f73562a&scene=0&xtrack=1#rd
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70]: /images/20230529/d28347dd390e4fa48da73515feb8867f.png