java 多线程CompletableFuture用法

引用

private final ThreadPoolTaskExecutor asyncTaskExecutor;

具体代码

CompletableFuture<Void> completableFuture1 = CompletableFuture.runAsync(()->{
            log.info("Future1 -  1");

            int num = 0;
            for (int i=0; i<80 ; i++){
                num++;
            }
            log.info("Future1 -  2");
            log.info("Future1 -  3");
            log.info("Future1 -  4");
         }, asyncTaskExecutor);
        CompletableFuture<Void> completableFuture2 = CompletableFuture.runAsync(()->{
            log.info("Future2 -  >>");
        }, asyncTaskExecutor);
        CompletableFuture<Void> completableFuture3 = CompletableFuture.runAsync(()->{
            log.info("Future3 -  >>");
        },asyncTaskExecutor);
        CompletableFuture<Void> completableFuture4 = CompletableFuture.runAsync(()->{
            log.info("Future4 -  >>");
        },asyncTaskExecutor);

等待结束

CompletableFuture.allOf(completableFuture1,completableFuture2,completableFuture3,completableFuture4);

完整方法

CompletableFuture<Void> completableFuture1 = CompletableFuture.runAsync(()->{
            log.info("Future1 -  1");

            int num = 0;
            for (int i=0; i<80 ; i++){
                num++;
            }
            log.info("Future1 -  2");
            log.info("Future1 -  3");
            log.info("Future1 -  4");
         }, asyncTaskExecutor);
        CompletableFuture<Void> completableFuture2 = CompletableFuture.runAsync(()->{
            log.info("Future2 -  >>");
        }, asyncTaskExecutor);
        CompletableFuture<Void> completableFuture3 = CompletableFuture.runAsync(()->{
            log.info("Future3 -  >>");
        },asyncTaskExecutor);
        CompletableFuture<Void> completableFuture4 = CompletableFuture.runAsync(()->{
            log.info("Future4 -  >>");
        },asyncTaskExecutor);

        CompletableFuture.allOf(completableFuture1,completableFuture2,completableFuture3,completableFuture4);
        log.info("结束了");