码迷,mamicode.com
首页 > 编程语言 > 详细

java CountDownLatch 控制异步和同步

时间:2018-09-17 16:19:53      阅读:178      评论:0      收藏:0      [点我收藏+]

标签:void   异步调用   color   ==   countdown   dex   ble   java   cte   

应用场景举例:

  执行A项目的方法,需要调用B项目、C项目、D项目的接口方法。

需求:

  异步调用B、C、D项目的接口方法,且每个接口都调用结束后,A项目的方法才可以结束。

注:如果需要获取接口返回结果,可以使用缓存(key,value)保存。线程只支持线程外的静态参数传递,不严谨。

package com.sze.redis.async;

import java.util.concurrent.CountDownLatch;

public class AsyncTest {
    public static void main(String[] args) throws InterruptedException {
        System.out.println("<=================A项目方法开始==============>");
        CountDownLatch latch = new CountDownLatch(3);
        Thread B = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("B项目接口调用===开始");
                try {
                    Thread.sleep(10000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("B项目接口调用===结束");
                latch.countDown();
            }
        });
        
        Thread C = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("C项目接口调用===开始");
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("C项目接口调用===结束");
                latch.countDown();
            }
        });
        
        Thread D = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("D项目接口调用===开始");
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("D项目接口调用===结束");
                latch.countDown();
            }
        });
        System.out.println("B C D start");
        B.start();
        C.start();
        D.start();
        latch.await();
        System.out.println("<=================A项目方法结束==============>");
    }
}

结果

<=================A项目方法开始==============>
B C D start
B项目接口调用===开始
D项目接口调用===开始
C项目接口调用===开始
D项目接口调用===结束
C项目接口调用===结束
B项目接口调用===结束
<=================A项目方法结束==============>

 

java CountDownLatch 控制异步和同步

标签:void   异步调用   color   ==   countdown   dex   ble   java   cte   

原文地址:https://www.cnblogs.com/zwcry/p/9662499.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!