摘要：將屏障重置為其初始狀態(tài)。注意，在由于其他原因造成損壞之后，實(shí)行重置可能會(huì)變得很復(fù)雜此時(shí)需要使用其他方式重新同步線(xiàn)程，并選擇其中一個(gè)線(xiàn)程來(lái)執(zhí)行重置。

1.線(xiàn)程限制 : 一個(gè)被線(xiàn)程限制的對(duì)象，由線(xiàn)程獨(dú)占，并且只能被占有它的線(xiàn)程修改
2.共享只讀 : 一個(gè)共享只讀的對(duì)象，在沒(méi)有額外同步的情況下，可以被多個(gè)線(xiàn)程并發(fā)訪(fǎng)問(wèn)，
但是任何線(xiàn)程都不能修改它
3.線(xiàn)程安全對(duì)象 : 一個(gè)線(xiàn)程安全的對(duì)象或則容器，在內(nèi)部通過(guò)同步機(jī)制來(lái)保證線(xiàn)程安全，
所以其他線(xiàn)程無(wú)需額外的同步就可以通過(guò)公共接口隨意訪(fǎng)問(wèn)它
4.被守護(hù)對(duì)象 : 被守護(hù)對(duì)象只能通過(guò)獲取特定的鎖來(lái)訪(fǎng)問(wèn)

采用synchronized關(guān)鍵字同步，缺點(diǎn) ：

不能完成做到線(xiàn)程安全

性能差

ArrayLisy -> Vector, Stack
HashMap -> HashTable (key、value不能為null)
Collections.synchronizedXXX(List、Set、Map)

ArrayList -> CopyOnWriteArrayList
HashSet、TreeSet -> CopyOnWriteArraySet ConcurrentSkipListSet
HashMap、TreeMap -> ConcurrentHashMap ConcurrentSkipListMap

AbstractQueuedSynchronizer - AQS

使用Node實(shí)現(xiàn)FIFO隊(duì)列，可以用于構(gòu)建鎖或則其他同步裝置的基礎(chǔ)框架

利用一個(gè)int類(lèi)型表示狀態(tài)

使用方法是基礎(chǔ)

子類(lèi)通過(guò)繼承并通過(guò)實(shí)現(xiàn)它的方法管理其狀態(tài) { acquire 和 release} 的方法操縱狀態(tài)

可以同時(shí)實(shí)現(xiàn)排他鎖和共享鎖模式（獨(dú)占、共享）

CountDownLatch
Semaphore
CyclicBarrier
ReentrantLock
Condition
FutureTask

CountDownLatch是一個(gè)同步工具類(lèi)，它允許一個(gè)或多個(gè)線(xiàn)程一直等待，直到其他線(xiàn)程執(zhí)行完后再執(zhí)行。例如，應(yīng)用程序的主線(xiàn)程希望在負(fù)責(zé)啟動(dòng)框架服務(wù)的線(xiàn)程已經(jīng)啟動(dòng)所有框架服務(wù)之后執(zhí)行。

CountDownLatch是通過(guò)一個(gè)計(jì)數(shù)器來(lái)實(shí)現(xiàn)的，計(jì)數(shù)器的初始化值為線(xiàn)程的數(shù)量。每當(dāng)一個(gè)線(xiàn)程完成了自己的任務(wù)后，計(jì)數(shù)器的值就相應(yīng)得減1。當(dāng)計(jì)數(shù)器到達(dá)0時(shí)，表示所有的線(xiàn)程都已完成任務(wù)，然后在閉鎖上等待的線(xiàn)程就可以恢復(fù)執(zhí)行任務(wù)。

@Self4j
public class CountDownLatchExample {

    private final  static int threadCount = 200;
    
    public static void main(String[] arg) {
    
        ExecutorService exec = Executors.newCachedThreadPool(); 
        
        final CountDownLatch lacth = new CountDownLatch(5);
        
        for (int i = 0; i < 1000; i++) {
            exec.excute( () -> {
            final int threadNum  = i;
            try {
                test(threadNum);
            } catch (Exception e) {
                log.error("exception", e);
            } finally {
                // latch遞減
                lacth.countDown();
            }
            });
        }
        // 等待latch計(jì)數(shù)器為0，則繼續(xù)往下執(zhí)行
        latch.await();
        // latch的await方法也可以傳入等待時(shí)間，等到等待時(shí)間后不管有沒(méi)完成計(jì)數(shù)都往下執(zhí)行
        // latch.await( 10, TimeUnit.MILLISECONDS);
        log.info("finished");
        exec.shutdown();
    }

    public static void test(int i)  throw Exception{
        log.info("thread: {}", i);
    }
}

Semaphore(int permits):構(gòu)造方法，創(chuàng)建具有給定許可數(shù)的計(jì)數(shù)信號(hào)量并設(shè)置為非公平信號(hào)量。
Semaphore(int permits,boolean fair):構(gòu)造方法，當(dāng)fair等于true時(shí)，創(chuàng)建具有給定許可數(shù)的計(jì)數(shù)信號(hào)量并設(shè)置為公平信號(hào)量。
void acquire():從此信號(hào)量獲取一個(gè)許可前線(xiàn)程將一直阻塞。
void acquire(int n):從此信號(hào)量獲取給定數(shù)目許可，在提供這些許可前一直將線(xiàn)程阻塞。
void release():釋放一個(gè)許可，將其返回給信號(hào)量。就如同車(chē)開(kāi)走返回一個(gè)車(chē)位。
void release(int n):釋放n個(gè)許可。
int availablePermits()：獲取當(dāng)前可用的許可數(shù)。
boolean tryAcquire()：僅在調(diào)用時(shí)此信號(hào)量存在一個(gè)可用許可，才從信號(hào)量獲取許可。
boolean tryAcquire(int permits)：僅在調(diào)用時(shí)此信號(hào)量中有給定數(shù)目的許可時(shí)，才從此信號(hào)量中獲取這些許可。

boolean tryAcquire(int permits,
                          long timeout,
                          TimeUnit unit)
                   throws InterruptedException

如果在給定的等待時(shí)間內(nèi)此信號(hào)量有可用的所有許可，并且當(dāng)前線(xiàn)程未被 中斷，則從此信號(hào)量獲取給定數(shù)目的許可。

@Self4j
public class SemaphoreExample {

    private final  static int threadCount = 200;

    public static void main(String[] arg) {

        ExecutorService exec = Executors.newCachedThreadPool(); 
    
        final Semaphore semaphore = new Semaphore(3);
    
        for (int i = 0; i < threadCount; i++) {
            exec.excute( () ）-> {
            final int threadNum  = i;
            try {
                // tryAcquire會(huì)嘗試去獲取一個(gè)信號(hào)量，如果獲取不到
                // 則什么都不會(huì)發(fā)生，走接下來(lái)的邏輯
                // if (semaphore.tryAcquire(1)) {
                //    test(i);
                //    semaphore.release();//釋放一個(gè)信號(hào)量
                // }
                semaphore.acquire();//獲取一個(gè)信號(hào)量
                test(i);
                semaphore.release();//釋放一個(gè)信號(hào)量
            } catch (Exception e) {
                log.error("exception", e);
            } 
            });
        }
        log.info("finished");
        exec.shutdown();
    }

    public static void test(int i)  throw Exception{
        log.info("thread: {}", i);
    }
}

一個(gè)同步輔助類(lèi)，它允許一組線(xiàn)程互相等待，直到到達(dá)某個(gè)公共屏障點(diǎn) (common barrier point)。

CyclicBarrier(int parties, Runnable barrierAction)
創(chuàng)建一個(gè)新的 CyclicBarrier，它將在給定數(shù)量的參與者（線(xiàn)程）處于等待狀態(tài)時(shí)啟動(dòng)，并在啟動(dòng) barrier 時(shí)執(zhí)行給定的屏障操作，該操作由最后一個(gè)進(jìn)入 barrier 的線(xiàn)程執(zhí)行。

CyclicBarrier(int parties)
創(chuàng)建一個(gè)新的 CyclicBarrier，它將在給定數(shù)量的參與者（線(xiàn)程）處于等待狀態(tài)時(shí)啟動(dòng)，但它不會(huì)在啟動(dòng) barrier 時(shí)執(zhí)行預(yù)定義的操作。

int await()
在所有 參與者都已經(jīng)在此 barrier 上調(diào)用 await 方法之前，將一直等待。

int await(long timeout,
                 TimeUnit unit)
          throws InterruptedException,
                 BrokenBarrierException,
                 TimeoutException

在所有 參與者都已經(jīng)在此屏障上調(diào)用 await 方法之前將一直等待,或者超出了指定的等待時(shí)間。

boolean isBroken() ： 查詢(xún)此屏障是否處于損壞狀態(tài)。

void reset() ：
將屏障重置為其初始狀態(tài)。如果所有參與者目前都在屏障處等待，則它們將返回，同時(shí)拋出一個(gè) BrokenBarrierException。注意，在由于其他原因造成損壞 之后，實(shí)行重置可能會(huì)變得很復(fù)雜；此時(shí)需要使用其他方式重新同步線(xiàn)程，并選擇其中一個(gè)線(xiàn)程來(lái)執(zhí)行重置。與為后續(xù)使用創(chuàng)建一個(gè)新 barrier 相比，這種方法可能更好一些。

int getNumberWaiting() ：返回當(dāng)前在屏障處等待的參與者數(shù)目。此方法主要用于調(diào)試和斷言。

@Self4j
public class CyclicBarrierExample {

    private final  static int threadCount = 200;
    
    private final static CyclicBarrier cyclicBarrier = new CyclicBarrier(7, 
        () -> {
        log.info("callback is running !");
        }
    );
    
    public static void main(String[] arg) {
    
        ExecutorService exec = Executors.newCachedThreadPool(); 
        
        for (int i = 0; i < threadCount; i++) {
            exec.excute( () -> {
                final int threadNum  = i;
                try {
                    race(i);
                } catch (Exception e) {
                    log.error("exception", e);
                } 
            });
        }
        log.info("finished");
        
        exec.shutdown();
    }
    
    public static void race(int i)  throw Exception{
        log.info("thread {} is ready", i);
        cyclicBarrier.await();
        log.info("thread {} is continue", i);
    }
}