java利用CompletableFuture实现多任务并行.大大节省调用时长

 
 1 直接上代码吧。java版本的。
背景是我有一个需求是用户注销。注销时我需要判断是否有订单，结算单等业务。这样我就需要调用其他业务线的接口。
接口需要调用N个（这里是5个）分别判断是否允许注销。
悲观假设每个接口调用要1s那么5个接口就需要5s以上，并且任何一个不可行则整个判断将不通过。
这时候就需要用到异步任务并行。 这里采用

CompletableFuture的thenCombine 来实现多个异步任务并行。代码简单。将两个test跑一下就可以看到效果，
异常case是将userId写成 >100的值。第4个任务将会抛错。这样就可以看到整体运行结果。
当然抛错也可以转换为自己认识的错误方式，由调用方来决定是否继续往下走。
本文为原创，虽然例子很简单但是可以解决我的需求。分享出来希望能帮到您，
当然如果您有更好的方式欢迎留言共同探讨，我的邮箱 [e-mail] 有更好的欢迎共同探讨。

import java.util.concurrent.CompletableFuture;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;

@Slf4j
public class SupplyAsyncText {

  @Test
  public void testSyncLogOff() {
    int userId = 45;
    // 同步
    long begin = System.currentTimeMillis();
    StringBuilder sb = new StringBuilder();
    sb.append(canDo1(userId));
    sb.append(canDo2(userId));
    sb.append(canDo3(userId));
    sb.append(canDo4(userId));
    sb.append(canDo5(userId));
    long end = System.currentTimeMillis();
    // 每一个执行1s 同步：结果是执行应该是 > 5s 的
    log.info("noUseAsync |{}|{} s", sb.toString(), (end - begin) / 1000.0);
  }

  @Test
  public void testCanLogOff() {
    // case 设定：如果 userId > 100 则在某一个环节抛错
    int userId = 10;
    // 异步 每一个执行1s 异步并行：结果是执行应该 < 5s
    long begin2 = System.currentTimeMillis();
    String result =
        CompletableFuture.supplyAsync(() -> canDo1(userId))
            .thenCombine(CompletableFuture.supplyAsync(() -> canDo2(userId)), (s1, s2) -> s1 + s2)
            .thenCombine(CompletableFuture.supplyAsync(() -> canDo3(userId)), (s1, s2) -> s1 + s2)
            .thenCombine(CompletableFuture.supplyAsync(() -> canDo4(userId)), (s1, s2) -> s1 + s2)
            .thenCombine(CompletableFuture.supplyAsync(() -> canDo5(userId)), (s1, s2) -> s1 + s2)
            .exceptionally(
                e -> {
                  log.error("exception: ", e);
                  return e.getMessage();
                })
            .join();
    long end2 = System.currentTimeMillis();
    log.info("supplyAsync|{}|{} s", result, (end2 - begin2) / 1000.0);
  }

  private String canDo1(int userId) {
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return "ok";
  }

  private String canDo2(int userId) {
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return "ok";
  }

  private String canDo3(int userId) {
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return "ok";
  }

  private String canDo4(int userId) {
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    if (userId > 100) {
      throw new RuntimeException(String.format("用户[%s]还有订单，不可注销",userId));
    }
    return "ok";
  }

  private String canDo5(int userId) {
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return "ok";
  }
}