关于java:多线程控制-countDownLatchCyclicBarrierSemaphore-总结

countDownLatch

作用：用于管制多线程执行协调，即线程先后依赖的问题。如主线程须要期待多个子线程执行实现后继续执行。

示例代码（代码中关键点正文）

public class CountDownTest {
    public static void main(String[] args) {
        long start = System.currentTimeMillis();
        System.out.println("start = " + start);
        int num = 100;
        LinkedBlockingQueue lbq = new LinkedBlockingQueue();
        lbq.stream().count();
        final CountDownLatch cdl = new CountDownLatch(num);//参数为线程个数
        for (int i = 0; i < num; i++) {
            new Thread(() -> {
                System.out.println("thread："+num);
                cdl.countDown();//此办法是CountDownLatch的线程数-1
            }).start();
        }
        try {
            cdl.await();
        }catch (InterruptedException e){
            e.printStackTrace();
        }
        // 通过await()调用，保障以下输入是最开端输入
        long end = System.currentTimeMillis();
        System.out.println("end = " + end);
        System.out.println("use" + (end - start));
    }
}

CyclicBarrier

作用：管制多个线程对立工夫执行

示例代码（代码中关键点正文）

public class CyclicBarrierTest {
    public static void main(String[] args) {
        int num = 5;
        CyclicBarrier cyclicBarrier = new CyclicBarrier(num);
        for(int i = 0;i<num;i++){
            new Thread(() -> {
                try {
                    Thread.sleep(num*1000);
                    System.out.println(new Date().getTime());
                    //以下调用将会使改线程参加到栅栏管制中，期待所有栅栏内线程全副初始化实现一起执行
                    //预期后果为多个线程输入的工夫戳完全一致
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

Semaphore

作用：管制多个线程同时执行的个数。相似工人和操作台，工人数量大于操作台

示例代码（代码中关键点正文）

public class SemaphoreTest {
    public static void main(String[] args) {
        int num = 3; //可执行线程数（操作台）
        int numThread = 20; //能参加的线程数 （工人）
        Semaphore semaphore = new Semaphore(num);
            for(int i = 0;i<numThread;i++){
                int no = i;
                new Thread(()->{
                    try {
                    semaphore.acquire(); //工人上工，占用一个操作台
                    System.out.println("工号："+ no +"的工人在干活");
                    Thread.sleep(5000);
                    System.out.println("工号："+ no +"的工人上班了");
                    semaphore.release(); //工人上班，开释操作台
                    }catch (Exception e){
                        e.printStackTrace();
                    }
                }).start();
            }
    }
}