Java 异步

迷南。 2023-10-15 16:07 20阅读 0赞

import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ExecutionException;
    
    public class AsyncExample {
        public static void main(String[] args) {
            // 前台任务：调用接口并返回结果
            CompletableFuture<String> frontTask = CompletableFuture.supplyAsync(() -> {
                // 模拟一些操作
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                return "前台任务执行成功，返回结果给客户端";
            });
    
            // 后台任务：执行计算方法
            frontTask.thenAcceptAsync(result -> {
                System.out.println(result);
                // 执行计算方法代码
                // 模拟一些耗时的操作
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("后台任务执行成功，计算结果已保存");
            });
    
            frontTask.join(); // 等待前台任务完成
        }
    }

// 前台调用接口
            CompletableFuture<Void> frontTask = CompletableFuture.runAsync(() -> {
                // 执行接口调用代码
                // 模拟一些操作
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("前台任务执行成功，返回结果给客户端");
            });
    
            // 后台异步继续执行计算任务
            frontTask.thenRunAsync(() -> {
                System.out.println("开始执行后台任务");
                // 执行计算任务代码
                // 模拟一些耗时的操作
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("后台任务执行成功，计算结果已保存");
            });