如何深入理解Java多線程與并發(fā)框中的并發(fā)輔助工具類，相信很多沒有經(jīng)驗的人對此束手無策，為此本文總結了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個問題。

創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供洪江網(wǎng)站建設、洪江做網(wǎng)站、洪江網(wǎng)站設計、洪江網(wǎng)站制作等企業(yè)網(wǎng)站建設、網(wǎng)頁設計與制作、洪江企業(yè)網(wǎng)站模板建站服務，10年洪江做網(wǎng)站經(jīng)驗，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡服務。

一、Exchanger 交換器（兩線程間的通信）

使用場景：用于 有且僅有兩個線程 間的 數(shù)據(jù)傳輸，就就是線程間的 通信 。它是 生產(chǎn)者/消費者 d的 wait() / notify() 的最佳替代工具。 核心原理：方法 exchange()阻塞特性：此方法被調(diào)用后等待其他線程來取數(shù)據(jù)，如果沒有其他線程取得數(shù)據(jù)，則一直 阻塞。

示例：交替打印奇偶數(shù)：

public class Print {
    public static void main(String[] args) {
    // 交換器
    Exchanger exchanger = new Exchanger<>();
    // 起始打印數(shù)值
    Integer startNumber = 1;
    // 終止的數(shù)值
    Integer endNumber= 100;
    // 線程1
    Thread t1 = new Thread(new Thread1(exchanger, startNumber, endNumber));
    Thread t2 = new Thread(new Thread2(exchanger, startNumber, endNumber));
    // 設置線程名稱
    t1.setName("thread-no-1");
    t2.setName("thread-no-2");
    // 啟動線程
    t1.start();
    t2.start();
}
}
/**
 * 打印奇數(shù)的線程
 */
class Thread1 implements Runnable {
private Exchanger exchanger;
/** 被打印的數(shù) */
private Integer number;
private final Integer endNumber;
public Thread1(Exchanger exchanger, Integer startNumber, Integer endNumber) {
    this.exchanger = exchanger;
    this.number = startNumber;
    this.endNumber = endNumber;
}
@Override
    public void run() {
    while (number <= endNumber) {
        if (number % 2 == 1) {
            System.out.println("線程：" + Thread.currentThread().getName() + " : " + number);
        }
        try {
            exchanger.exchange(number++);
        }
        catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
}
/**
 * 打印偶數(shù)的線程
 */
class Thread2 implements Runnable {
private Exchanger exchanger;
/** 被打印的數(shù) */
private Integer number;
private final Integer endNumber;
public Thread2(Exchanger exchanger, Integer startNumber, Integer endNumber) {
    this.exchanger = exchanger;
    this.number = startNumber;
    this.endNumber = endNumber;
}
@Override
    public void run() {
    while (number <= endNumber) {
        if (number % 2 == 0) {
            System.out.println("線程：" + Thread.currentThread().getName() + " : " + number);
        }
        try {
            exchanger.exchange(number++);
        }
        catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
}

二、Semaphore 信號燈

核心原理： 通過發(fā)放設置最大 許可數(shù)，來限制線程的并發(fā)數(shù)。 默認是 非公平鎖，效率高。

public Semaphore(int permits) {
    sync = new NonfairSync(permits);
}
Semaphore semaphore = new Semaphore(5);
try {
    semaphore.acquire();
    // 獲取許可
    // 邏輯
}
catch (InterruptedException e) {
    e.printStackTrace();
}
finally {
    semaphore.release();
    // 釋放許可
}

三、CountDownLatch 倒計時閂（鎖）

核心原理：線程以 組團 的方式進行任務。 count 作為 stat 狀態(tài)。await() 方式將 阻塞當前線程，直到 count 為 0。

CountDownLatch countDownLatch = new CountDownLatch(5);
countDownLatch.countDown();
// count - 1
// 預處理
try {
    countDownLatch.await();
    // 阻塞當前線程
    // 大家一起處理的時候，我才處理
}
catch (InterruptedException e) {
    e.printStackTrace();
}

Sync同步器

private static final class Sync extends AbstractQueuedSynchronizer {
    private static final long serialVersionUID = 4982264981922014374L;
    Sync(int count) {
        setState(count);
    }
    int getCount() {
        return getState();
    }
    protected int tryAcquireShared(int acquires) {
        return (getState() == 0) ? 1 : -1;
    }
    protected Boolean tryReleaseShared(int releases) {
        // 遞減 count; 轉換為零時發(fā)出信號
        for (;;) {
            int c = getState();
            if (c == 0)
                            return false;
            int nextc = c-1;
            if (compareAndSetState(c, nextc))
                            return nextc == 0;
        }
    }
}

四、CyclicBarrier 循環(huán)柵欄（循環(huán)鎖）

核心原理： 基于 ReentrantLock 和 Condition。 CyclicBarrier 不僅具有 CountDownLatch 的功能，還有實現(xiàn)屏障等待的功能，也就是階段性同步。

CyclicBarrier與CountDownLatch比較

• CountDownLatch:一個線程(或者多個)，等待另外N個線程完成某個事情之后才能執(zhí)行；CyclicBarrier:N個線程相互等待，任何一個線程完成之前，所有的線程都必須等待。

• CountDownLatch:一次性的；CyclicBarrier:可以重復使用。

• CountDownLatch基于AQS；CyclicBarrier基于鎖和Condition。本質上都是依賴于volatile和CAS實現(xiàn)的。

看完上述內(nèi)容，你們掌握如何深入理解Java多線程與并發(fā)框中的并發(fā)輔助工具類的方法了嗎？如果還想學到更多技能或想了解更多相關內(nèi)容，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！