CountDownLatch 部分加載和同時併發業務。

按順序部分加載：

import java.util.concurrent.CountDownLatch;

/**
 * @Title: ThreadCountDownTest.java
 * @Description:
 * @author: wuwenjie
 * @date: 2019.07.17 16:43
 * 
 */
public class ThreadCountDownTest {

    public static void main(String[] args) {
// 初始化閉鎖，並設置資源個數
        CountDownLatch latch = new CountDownLatch(2);

        Thread t1 =new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(1000);
　　　　　　　　　　　　//加載1
                    latch.countDown();
                    System.out.println(111);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });


        Thread t2 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(12000);
　　　　　　　　　　　　//加載2
                    latch.countDown();
                    System.out.println(222);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        Thread t3 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
　　　　　　　　　　　　
                    latch.await();
　　　　　　　　　　　　　//加載完成業務使用
                    System.out.println(333);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        t1.start();
        t2.start();
        t3.start();

    }

}

 

2.同時業務併發處

import java.util.concurrent.CountDownLatch; public class ThreadCountDownTest { public static void main(String[] args) { // 初始化閉鎖，並設置資源個數
        CountDownLatch latch = new CountDownLatch(2); Thread t1 =new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(1000); latch.countDown();
　　　　　　　　　　　　//等待全部執行完，併發 latch.await();
 System.out.println(111); } catch (InterruptedException e) { e.printStackTrace(); } } }); Thread t2 = new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(12000); latch.countDown(); latch.await(); System.out.println(222); } catch (InterruptedException e) { e.printStackTrace(); } } }); Thread t3 = new Thread(new Runnable() { @Override public void run() { try { latch.await(); System.out.println(333); } catch (InterruptedException e) { e.printStackTrace(); } } }); t1.start(); t2.start(); t3.start(); } }