当所有异步spring集成流/线程执行完成时，实现回调机制/通知的策略

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.stereotype.Service;

import java.util.concurrent.Future;

@Service
public class AsyncService {

    @Async
    public Future<String> doAsyncTask() {
        // 模拟异步任务
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new AsyncResult<>("Task completed");
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

@Component
public class AsyncCaller {

    @Autowired
    private AsyncService asyncService;

    public void callAsyncTask() {
        Future<String> future = asyncService.doAsyncTask();
        try {
            String result = future.get(); // 阻塞等待任务完成
            System.out.println(result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }
}

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.concurrent.CompletableFuture;

@Service
public class AsyncService {

    @Async
    public CompletableFuture<String> doAsyncTask() {
        // 模拟异步任务
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return CompletableFuture.completedFuture("Task completed");
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.concurrent.CompletableFuture;

@Component
public class AsyncCaller {

    @Autowired
    private AsyncService asyncService;

    public void callAsyncTask() {
        CompletableFuture<String> future = asyncService.doAsyncTask();
        future.thenAccept(result -> {
            System.out.println(result); // 异步任务完成后的回调处理
        });
    }
}