在Spring框架中如何同时运行两线程并按需设置返回结果？

1. 开启Spring异步支持 #

首先在Spring项目中启用异步功能，只需在配置类或启动类上添加@EnableAsync注解：

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;

@Configuration
@EnableAsync
public class AsyncConfig {
}

2. 编写异步任务方法 #

创建异步任务类，用@Async标记需要并行执行的取数方法。注意：异步方法不能与调用方在同一类中，否则Spring动态代理无法生效。

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.util.concurrent.CompletableFuture;

@Component
public class DataFetchTask {

    // 第一个线程的取数逻辑
    @Async
    public CompletableFuture<String> fetchFirstData() {
        // 模拟业务耗时操作（实际替换为接口调用/数据库查询等逻辑）
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        // 模拟返回空的场景，实际按业务逻辑返回数据
        return CompletableFuture.completedFuture(null);
    }

    // 第二个线程的取数逻辑
    @Async
    public CompletableFuture<String> fetchSecondData() {
        try {
            Thread.sleep(1500);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        // 模拟返回有效数据
        return CompletableFuture.completedFuture("从第二个线程获取的有效数据");
    }
}

3. 业务逻辑实现并行调用与结果处理 #

在业务服务类中注入异步任务类，同时启动两个线程，优先取第一个线程的结果，为空则 fallback 到第二个线程的结果：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

@Service
public class DataService {

    @Autowired
    private DataFetchTask dataFetchTask;

    public String getFinalData() throws ExecutionException, InterruptedException {
        // 同时启动两个异步任务
        CompletableFuture<String> firstFuture = dataFetchTask.fetchFirstData();
        CompletableFuture<String> secondFuture = dataFetchTask.fetchSecondData();

        // 优先等待第一个任务完成并获取结果
        String firstResult = firstFuture.get();
        
        if (firstResult != null && !firstResult.isEmpty()) {
            return firstResult;
        }

        // 第一个结果为空，直接返回第二个任务的结果（无论是否为空）
        return secondFuture.get();
    }
}

额外注意事项 #

• 若需处理异步任务的异常，可通过CompletableFuture的exceptionally回调捕获，避免业务流程中断：

  CompletableFuture<String> firstFuture = dataFetchTask.fetchFirstData()
          .exceptionally(e -> {
              // 异常场景下返回null或默认值，适配后续判断逻辑
              return null;
          });
  

• 如果不需要优先等待第一个任务，也可以用CompletableFuture.allOf()等待所有任务完成后再判断，但会增加整体等待时间，不符合本次需求的优先级逻辑。

内容的提问来源于stack exchange，提问作者Elbrus Hasanzade