動機

• 自 Java 5 以來，該平臺在 java.util.concurrent 包中提供了高級并發(fā)實用程序。
• 它們?nèi)〈耸謩忧覐?fù)雜的等待和通知的使用。
• 它們更安全、更易于使用，減少了并發(fā)代碼中出錯的可能性。

java.util.concurrent 中的并發(fā)實用程序
實用類別：

• 執(zhí)行器框架：第 80 條中介紹的線程管理。
• 并發(fā)集合：List、Queue 和 Map 等標(biāo)準(zhǔn)集合的線程安全實現(xiàn)。
• 同步器：線程之間的協(xié)調(diào)，包括 CountDownLatch、Semaphore、CyclicBarrier、Exchanger 和 Phaser。

競爭系列

特點：

• 內(nèi)部同步以獲得高性能。
• 他們不允許排除競爭活動。
• 像 putIfAbsent 這樣的原子操作提高了安全性和可用性。 示例：線程安全 Map 的實現(xiàn)：

Map<String, String> map = new ConcurrentHashMap<>();
String result = map.putIfAbsent("key", "value");
if (result == null) {
    System.out.println("Valor inserido.");
} else {
    System.out.println("Chave já existente com valor: " + result);
}

好處：

• 替換同步集合（Collections.synchronizedMap）。
• 競爭應(yīng)用程序的性能顯著提高。

同步器
目的：線程之間的協(xié)調(diào)。

常見同步器示例：

• CountDownLatch：用于線程協(xié)調(diào)的一次性屏障。
• 信號量：控制對共享資源的訪問。
• CyclicBarrier：在可重用屏障點進行同步。
• Phaser：高級動態(tài)線程同步。

實際示例：使用 CountDownLatch 進行并發(fā)計時
目的：測量多個線程同時執(zhí)行的時間。

實施：

public static long time(Executor executor, int concurrency, Runnable action) throws InterruptedException {
    CountDownLatch ready = new CountDownLatch(concurrency);
    CountDownLatch start = new CountDownLatch(1);
    CountDownLatch done = new CountDownLatch(concurrency);

    for (int i = 0; i < concurrency; i++) {
        executor.execute(() -> {
            try {
                ready.countDown(); // Indica que está pronto
                start.await();     // Aguarda o sinal de início
                action.run();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } finally {
                done.countDown(); // Indica que terminou
            }
        });
    }

    ready.await();   // Aguarda todas as threads ficarem prontas
    long startTime = System.nanoTime();
    start.countDown(); // Dispara o sinal de início
    done.await();     // Aguarda todas as threads finalizarem
    return System.nanoTime() - startTime;
}

注釋：

• 使用三個鎖存器：ready（表示準(zhǔn)備就緒）、start（初始觸發(fā)）和done（最終確定）。
• 使用 System.nanoTime 精確測量時間間隔。

等待和通知的當(dāng)前實踐
僅用于遺留代碼維護。
主要規(guī)則：

1. 調(diào)用 wait 時始終使用循環(huán)：

synchronized (lock) {
    while (!condition) {
        lock.wait();
    }
}

1. 測試等待前后的狀況。
2. 避免依賴notify，首選notifyAll。

結(jié)論

• 盡可能使用有競爭力的實用程序。
• 它們使代碼更具可讀性、安全性和效率。
• 現(xiàn)代替代方案（如 CyclicBarrier 或 Phaser）可以取代基于等待和通知的模式

書中的例子

以上是項目 更喜歡并發(fā)實用程序來等待和通知的詳細(xì)內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！