java多線程JUC常用輔助類詳解

更新時(shí)間：2021年09月27日 15:30:16 作者：不會(huì)編程的派大星

這篇文章主要為大家介紹了java多線程及并發(fā)編程中JUC常用輔助類，文中附含詳細(xì)示例代碼，有需要的朋友可以借鑒參考下，希望能夠有所幫助

1.countDownLatch

減法計(jì)數(shù)器：實(shí)現(xiàn)調(diào)用幾次線程后，在觸發(fā)另一個(gè)任務(wù)

在這里插入圖片描述

簡單代碼實(shí)現(xiàn)：

舉例說明：就像五個(gè)人在同一房間里，有一個(gè)看門的大爺，當(dāng)五個(gè)人都出去后，他才能鎖門，也就是說執(zhí)行5次出門這個(gè)動(dòng)作的線程后，才出發(fā)了鎖門的這個(gè)動(dòng)作

import java.util.concurrent.CountDownLatch;
/**
 * @program: juc
 * @description
 * @author: 不會(huì)編程的派大星
 * @create: 2021-04-24 16:55
 **/
public class CountDownLatchTest {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(5);
        System.out.println("door is open");
        for (int i = 1; i <= 5 ; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName()+" is going out");
                countDownLatch.countDown();
            },String.valueOf(i)).start();
        }
        countDownLatch.await();
        System.out.println("door is closed");
    }
}

代碼運(yùn)行結(jié)果：

在這里插入圖片描述

基本原理：

countDownLatch.countDown(); // 數(shù)量-1

countDownLatch.await(); // 等待計(jì)數(shù)器歸零，然后再向下執(zhí)行

每次有線程調(diào)用 countDown() 數(shù)量-1，假設(shè)計(jì)數(shù)器變?yōu)?，countDownLatch.await() 就會(huì)被喚醒，繼續(xù)執(zhí)行！

2.CyclicBarrier

在這里插入圖片描述

這里我們簡單理解為加法計(jì)數(shù)器

簡單代碼實(shí)現(xiàn)：

舉例說明：這里只要集齊7顆龍珠，就執(zhí)行打印 “7顆龍珠集齊了”的線程，這里我們先設(shè)置線程計(jì)數(shù)為8，看看會(huì)不會(huì)執(zhí)行打印的線程，然后在執(zhí)行計(jì)數(shù)為7的情況

1.cyclicBarrier計(jì)數(shù)為8的時(shí)候，執(zhí)行線程數(shù)量為7的時(shí)候：

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
/**
 * @program: juc
 * @description
 * @author: 不會(huì)編程的派大星
 * @create: 2021-04-24 17:31
 **/
public class CyclicBarrierTest {
    public static void main(String[] args) {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(8,new myThread());
        for (int i = 1; i <= 7 ; i++) {
            int finalI = i;
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName()+"收集了"+ finalI+"顆龍珠");
                try {
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            },String.valueOf(i)).start();
        }
    }
}
class myThread implements Runnable{
    @Override
    public void run() {
        System.out.println("7顆龍珠集齊啦");
    }
}

執(zhí)行結(jié)果：

在這里插入圖片描述

2.cyclicBarrier計(jì)數(shù)為1的時(shí)候，執(zhí)行線程數(shù)量為7的時(shí)候：

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
/**
 * @program: juc
 * @description
 * @author: 不會(huì)編程的派大星
 * @create: 2021-04-24 17:31
 **/
public class CyclicBarrierTest {
    public static void main(String[] args) {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7,new myThread());
        for (int i = 1; i <= 7 ; i++) {
            int finalI = i;
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName()+"收集了"+ finalI+"顆龍珠");
                try {
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            },String.valueOf(i)).start();
        }
    }
}
class myThread implements Runnable{
    @Override
    public void run() {
        System.out.println("7顆龍珠集齊啦");
    }
}

執(zhí)行結(jié)果：

在這里插入圖片描述

可以看到

  CyclicBarrier cyclicBarrier = new CyclicBarrier(7,new myThread());

當(dāng)執(zhí)行完7個(gè)線程后，才會(huì)執(zhí)行一個(gè)實(shí)現(xiàn)了Runnable接口的線程

3.Semaphore

在這里插入圖片描述

簡單代碼實(shí)現(xiàn)：
舉例說明：搶車位，6個(gè)車，最多同時(shí)只能有三個(gè)車進(jìn)

import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
/**
 * @program: juc
 * @description
 * @author: 不會(huì)編程的派大星
 * @create: 2021-04-24 18:26
 **/
public class SemaphoreTest {
    public static void main(String[] args)  {
        //線程數(shù)量 ，停車位，,6輛車在等，最多只能同時(shí)進(jìn)來三個(gè) 限流
        Semaphore semaphore = new Semaphore(3);
        for (int i = 1; i <= 6 ; i++) {
            new Thread(() -> {
                try {
                    semaphore.acquire();//獲得
                    System.out.println(Thread.currentThread().getName()+"搶到車位了");
                    TimeUnit.SECONDS.sleep(3);
                    System.out.println(Thread.currentThread().getName()+"離開車位了");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    semaphore.release(); //釋放
                }
            },String.valueOf(i)).start();
        }
    }
}

運(yùn)行結(jié)果：

在這里插入圖片描述