Springboot异步任务+异步回调实现多个异步任务并行执行

╰半夏微凉° 2022-09-06 13:28 277阅读 0赞

## Springboot异步任务+异步回调实现多个异步任务并行执行 ##

**今天写项目的时候以为访问数据库慢，之后突然想起了异步任务不是可以并行执行方法嘛，之后我就顺着这个思路研究气了异步任务。**

**想要达到效果**：controller层进来调用service得多个方法获取数据，但是又需要异步任务没有执行完不能结束掉controller方法，所以需要等待调用的service方法执行完毕，获得了数据 处理好之后再往下执行。

这个时候就需要用到异步回调了

我们模拟一个这样的效果：

实体类：

public class User { 
        private String name;
        private String sex;
    }

service层：

@Service
    public class BinxingAsyncService { 
    
        @Async
        public Future<List<User>> diReturn1(){ 
            try { 
                Thread.sleep(3000);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
            ArrayList<User> users = new ArrayList<>();
            users.add(new User("yang1","男"));
            users.add(new User("yang2","男"));
            System.out.println("111");
    
            return new AsyncResult<>(users);
        }
    
        @Async
        public Future<List<User>> diReturn2(){ 
            ArrayList<User> users = new ArrayList<>();
            users.add(new User("yang3","男"));
            users.add(new User("yang4","男"));
            System.out.println("222");
    
            return new AsyncResult<>(users);
        }
    }

controller层：

@RestController
    public class BinxingAsyncController { 
        @Autowired
        BinxingAsyncService binxingAsyncService;
    
        @GetMapping("bin")
        public List<User> bin(){ 
            ArrayList<User> users = new ArrayList<>();
    
            Future<List<User>> listFuture = binxingAsyncService.diReturn1();
            Future<List<User>> listFuture1 = binxingAsyncService.diReturn2();
            try { 
                users.addAll(listFuture.get());
                System.out.println(listFuture);
                users.addAll(listFuture1.get());
                System.out.println(listFuture1);
                System.out.println("主线程");
                return users;
            } catch (Exception e) { 
                e.printStackTrace();
            }
            return null;
        }
    }

后台打印  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aHV6aHV5YW5n_size_16_color_FFFFFF_t_70]

之后我们执行看看页面效果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aHV6aHV5YW5n_size_16_color_FFFFFF_t_70 1]  
这样就发现实现了我们想要得效果。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aHV6aHV5YW5n_size_16_color_FFFFFF_t_70]: /images/20220829/f53692f21d834a22ba717b49b0def828.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aHV6aHV5YW5n_size_16_color_FFFFFF_t_70 1]: /images/20220829/26f2af70ea234e1cb9a4f12234a1bf8b.png