SpringBoot異步多線程調用注解@Async使用和CountDownLatch配合使用案例

zhuan:https://blog.csdn.net/weixin_43168010/article/details/103512942

@Autowired
    private Test test;
    @Override
    public List<Integer> findByMonth() {
        List<Integer> list = new ArrayList<>();
        for (int i =1;i<=12;i++){
            int count= baseMapper.findByMonth(i);
            list.add(count);
        }
        CountDownLatch countDownLatch = new CountDownLatch(6);
        System.out.println("開始執行多線程任務1111111111:::"+System.currentTimeMillis());
        for (int i =0;i<=5;i++){
            test.doTaskThree(countDownLatch,i);
 
        }
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("主線程繼續執行222222222222222:::::"+Thread.currentThread().getName());
        return list;
 
 
 
 
 
 
 
 
@Component
public class Test {
    //注意這個多線程方法的類一定要加@Component注解，拿給spring容器管理
    @Async
    public void doTaskThree(CountDownLatch countDownLatch,int i) {
        long start = System.currentTimeMillis();
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        long end = System.currentTimeMillis();
        System.out.println("第00" + i + "完成任務，耗時：" + (end - start) + "毫秒，線成名為::" + Thread.currentThread().getName());
        countDownLatch.countDown();
    }
 
}

 

開始執行多線程任務1111111111:::1576198763725
第005完成任務，耗時：10000毫秒，線成名為::SimpleAsyncTaskExecutor-6
第004完成任務，耗時：10000毫秒，線成名為::SimpleAsyncTaskExecutor-5
第000完成任務，耗時：10000毫秒，線成名為::SimpleAsyncTaskExecutor-1
第003完成任務，耗時：10000毫秒，線成名為::SimpleAsyncTaskExecutor-4
第002完成任務，耗時：10000毫秒，線成名為::SimpleAsyncTaskExecutor-3
第001完成任務，耗時：10000毫秒，線成名為::SimpleAsyncTaskExecutor-2
主線程繼續執行222222222222222:::::http-nio-8300-exec-1

　

@Bean("getTaskExector")
    public Executor executor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        int threadCount = Runtime.getRuntime().availableProcessors();
        executor.setCorePoolSize(threadCount);//核心池大小
        executor.setMaxPoolSize(threadCount);//最大線程數
        executor.setQueueCapacity(1000);//隊列程度
        executor.setKeepAliveSeconds(1000);//線程空閑時間
        executor.setThreadNamePrefix("tsak-asyn");//線程前綴名稱
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());//配置拒絕策略
        return executor;
    }

　　

開始執行多線程任務1111111111:::1576200103134
第002完成任務，耗時：10000毫秒，線成名為::tsak-asyn3
第001完成任務，耗時：10000毫秒，線成名為::tsak-asyn2
第003完成任務，耗時：10000毫秒，線成名為::tsak-asyn4
第005完成任務，耗時：10000毫秒，線成名為::tsak-asyn6
第004完成任務，耗時：10000毫秒，線成名為::tsak-asyn5
第000完成任務，耗時：10000毫秒，線成名為::tsak-asyn1
主線程繼續執行222222222222222:::::http-nio-8300-exec-3
 
開始執行多線程任務1111111111:::1576200126619
第003完成任務，耗時：10000毫秒，線成名為::tsak-asyn2
第004完成任務，耗時：10000毫秒，線成名為::tsak-asyn4
第001完成任務，耗時：10000毫秒，線成名為::tsak-asyn8
第000完成任務，耗時：10000毫秒，線成名為::tsak-asyn7
第005完成任務，耗時：10000毫秒，線成名為::tsak-asyn6
第002完成任務，耗時：10000毫秒，線成名為::tsak-asyn3
主線程繼續執行222222222222222:::::http-nio-8300-exec-2
 
開始執行多線程任務1111111111:::1576200167044
第005完成任務，耗時：10001毫秒，線成名為::tsak-asyn7
第003完成任務，耗時：10001毫秒，線成名為::tsak-asyn4
第004完成任務，耗時：10001毫秒，線成名為::tsak-asyn8
第000完成任務，耗時：10001毫秒，線成名為::tsak-asyn5
第002完成任務，耗時：10001毫秒，線成名為::tsak-asyn2
第001完成任務，耗時：10001毫秒，線成名為::tsak-asyn1
主線程繼續執行222222222222222:::::http-nio-8300-exec-1

 

///////////////////////

 

@Async("getTaskExector")
    public Future<String> doTaskThree(int i) {
        long start = System.currentTimeMillis();
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        long end = System.currentTimeMillis();
        System.out.println("第00" + i + "完成任務，耗時：" + (end - start) + "毫秒，線成名為::" + Thread.currentThread().getName());
        return new AsyncResult("SUCUESS");
    }
 
 
 
 
 
System.out.println("開始執行多線程任務1111111111:::"+System.currentTimeMillis());
        List<Future<String>> list1 = new ArrayList<>();
        for (int i =0;i<=5;i++){
            Future<String> stringFuture = test.doTaskThree(i);
            list1.add(stringFuture);
        }
        boolean flag = false;
        while (!flag){
            for (Future<String> future:list1){
                try {
                    String s = future.get();
                    if (s =="成功"){
                        flag = true;
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
        System.out.println("主線程繼續執行222222222222222:::::"+Thread.currentThread().getName());