Java多線程之循環(huán)柵欄技術CyclicBarrier使用探索
第1章：引言
工作中，咱們經常會遇到需要多個線程協同工作的情況。CyclicBarrier，直譯過來就是“循環(huán)屏障”。它是Java中用于管理一組線程，并讓它們在某個點上同步的工具。簡單來說，咱們可以把一群線程想象成一隊馬拉雪橇的馴鹿，CyclicBarrier就像是一個指定的集合點，所有馴鹿必須到齊了，才能繼續(xù)下一段旅程。
不過別擔心，這聽起來比實際復雜。實際上，CyclicBarrier提供了一種簡單的方式來達到這個同步目的。它通過一個計數器來實現，這個計數器初始值是線程的數量。當一個線程到達屏障點時，計數器就減一。當計數器減到0時，表示所有線程都到齊了，然后咱們可以執(zhí)行一些操作，或者繼續(xù)執(zhí)行下一步。
第2章：CyclicBarrier基礎
要深入理解CyclicBarrier，咱們首先得知道它是怎么工作的。CyclicBarrier在Java的java.util.concurrent包中，是并發(fā)編程的一部分。它主要用于讓一組線程互相等待，直到所有線程都達到了一個公共屏障點（Barrier Point），然后這些線程才繼續(xù)執(zhí)行。
讓小黑舉個簡單的例子。假設咱們有一個任務，需要四個線程同時開始執(zhí)行。這就可以用CyclicBarrier來實現。小黑寫了下面這段代碼，來展示基本的用法：
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierExample {
public static void main(String[] args) {
// 創(chuàng)建一個新的CyclicBarrier，其中包括4個線程
CyclicBarrier barrier = new CyclicBarrier(4, () -> System.out.println("所有線程到達屏障點，可以繼續(xù)執(zhí)行！"));
// 創(chuàng)建四個線程
for (int i = 0; i < 4; i++) {
int threadNum = i;
new Thread(() -> {
try {
System.out.println("線程 " + threadNum + " 正在執(zhí)行任務");
Thread.sleep(1000); // 模擬任務執(zhí)行時間
System.out.println("線程 " + threadNum + " 到達屏障點");
barrier.await(); // 等待其他線程
System.out.println("線程 " + threadNum + " 繼續(xù)執(zhí)行其他任務");
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}
}
}
在這個例子中，咱們創(chuàng)建了一個CyclicBarrier實例，這個實例要求四個線程都達到屏障點后才能繼續(xù)執(zhí)行。每個線程在執(zhí)行自己的任務后，會調用barrier.await();來等待其他線程。所有線程都調用了await()方法后，計數器變?yōu)?，屏障就被克服了，每個線程繼續(xù)執(zhí)行它們之后的任務。
第3章：CyclicBarrier的核心特性
了解了CyclicBarrier的基本用法后，咱們來深入探討一下它的核心特性。這些特性讓CyclicBarrier成為并發(fā)編程中一個非常有用的工具，特別是在處理多線程同步問題時。
重用性
CyclicBarrier的一個顯著特點是它的重用性。這意味著一旦所有等待線程都到達屏障，它就可以重置并重用。這個特性使得CyclicBarrier非常適合于那些需要多次等待一組線程到達同一點的情況。
讓小黑用一個例子來說明這一點。假設咱們有一個處理數據的多階段任務，每個階段都需要所有線程完成后才能進入下一階段。這里就可以運用CyclicBarrier的重用性。
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierReuseExample {
private static final int THREAD_COUNT = 3;
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> System.out.println("所有線程完成當前階段，準備進入下一階段！"));
for (int i = 0; i < THREAD_COUNT; i++) {
int threadNum = i;
new Thread(() -> {
try {
for (int phase = 1; phase <= 3; phase++) { // 假設有三個階段
System.out.println("線程 " + threadNum + " 完成階段 " + phase);
barrier.await(); // 等待其他線程
}
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}
}
}在這個例子中，每個線程都會經歷三個階段。每個階段都使用相同的CyclicBarrier來同步線程。線程完成一個階段后，就會等待其他線程。一旦所有線程都完成了該階段，CyclicBarrier就會重置，讓線程開始下一個階段。
同步輔助功能
CyclicBarrier還提供了一個同步輔助功能：當所有線程都到達屏障時，可以執(zhí)行一個預定義的動作。這是通過在CyclicBarrier的構造函數中提供一個Runnable來實現的。
這個功能非常有用，因為它允許咱們在所有線程都到達屏障后，執(zhí)行一些處理，比如更新共享資源、合并結果等。小黑再來給大家展示一個例子：
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierActionExample {
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("全部線程已到達屏障點，執(zhí)行屏障動作"));
for (int i = 0; i < 3; i++) {
new Thread(() -> {
try {
System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務");
Thread.sleep(2000); // 模擬任務執(zhí)行時間
barrier.await(); // 等待其他線程
System.out.println(Thread.currentThread().getName() + " 繼續(xù)執(zhí)行后續(xù)任務");
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}
}
}
在這個代碼中，當所有線程都到達屏障點時，會執(zhí)行一段指定的代碼，即打印出“全部線程已到達屏障點，執(zhí)行屏障動作”。這樣的設計使得CyclicBarrier不僅僅是一個同步工具，還可以作為線程間協調的一種手段。
通過這些特性，CyclicBarrier成為了處理復雜同步問題的有力工具。它不僅能確保線程在繼續(xù)執(zhí)行前達到某個公共點，還能夠在所有線程都準備好后執(zhí)行。
第4章：CyclicBarrier的實際應用場景
并行計算
一個典型的應用場景是并行計算。假設咱們有一個大數據集，需要進行復雜的數據處理，這個處理過程可以分解為多個獨立的子任務，每個子任務由一個單獨的線程處理。但在進行下一步處理之前，必須確保所有子任務都完成了當前步驟。這里就是CyclicBarrier大顯身手的時候。
來看看下面這個例子，小黑寫了一段代碼，模擬了這種情況：
import java.util.concurrent.CyclicBarrier;
public class ParallelComputationExample {
private static final int THREAD_COUNT = 4;
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> System.out.println("所有子任務處理完成，準備進入下一步！"));
for (int i = 0; i < THREAD_COUNT; i++) {
new Thread(new Worker(i, barrier)).start();
}
}
static class Worker implements Runnable {
private final int threadNumber;
private final CyclicBarrier barrier;
Worker(int threadNumber, CyclicBarrier barrier) {
this.threadNumber = threadNumber;
this.barrier = barrier;
}
@Override
public void run() {
try {
System.out.println("線程 " + threadNumber + " 正在處理任務");
Thread.sleep(2000); // 模擬任務處理時間
System.out.println("線程 " + threadNumber + " 完成任務，等待其他線程");
barrier.await(); // 等待其他線程完成
} catch (Exception e) {
e.printStackTrace();
}
}
}
}在這個例子中，咱們創(chuàng)建了四個線程，每個線程都代表一個數據處理任務。這些線程在完成自己的任務后，會等待其他線程完成，然后一起進入下一步。
第5章：深入CyclicBarrier的API
咱們已經看到了CyclicBarrier在實際場景中的一些應用，現在小黑要帶大家更深入地了解一下CyclicBarrier的API。理解這些API對于充分利用CyclicBarrier的功能是至關重要的。
基本方法
CyclicBarrier提供了一些核心的方法來控制線程間的同步：
CyclicBarrier(int parties): 這是CyclicBarrier的構造函數，parties指的是必須調用await方法的線程數量。CyclicBarrier(int parties, Runnable barrierAction): 這個構造函數除了指定線程數外，還可以指定當所有線程都到達屏障時，要執(zhí)行的操作。await(): 線程調用這個方法告訴CyclicBarrier它已到達屏障點。如果所有線程都到達屏障，它們就會繼續(xù)執(zhí)行；否則，調用await的線程會阻塞，等待其他線程。
示例：使用CyclicBarrier同步任務
為了更好地理解這些API，小黑準備了一個具體的例子。假設咱們有一個任務，需要多個線程協作完成，每個線程執(zhí)行完各自的部分后，需要等待其他線程也執(zhí)行完畢，然后統一進行下一步操作。
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierApiExample {
public static void main(String[] args) {
// 定義一個新的CyclicBarrier，需要3個線程協作
CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("所有線程準備就緒，開始下一步操作"));
for (int i = 0; i < 3; i++) {
new Thread(new Task(barrier), "線程 " + i).start();
}
}
static class Task implements Runnable {
private final CyclicBarrier barrier;
Task(CyclicBarrier barrier) {
this.barrier = barrier;
}
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務");
Thread.sleep(1000); // 模擬任務執(zhí)行時間
System.out.println(Thread.currentThread().getName() + " 完成任務，等待其他線程");
barrier.await(); // 等待其他線程
System.out.println(Thread.currentThread().getName() + " 開始執(zhí)行后續(xù)操作");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}在這個例子中，每個線程都在執(zhí)行它的任務。完成任務后，它會等待其他線程也完成任務。只有當所有線程都執(zhí)行了barrier.await()方法之后，才會執(zhí)行CyclicBarrier的barrierAction，即打印出“所有線程準備就緒，開始下一步操作”。
異常處理
處理異常也是使用CyclicBarrier時需要考慮的一個重要方面。如果任何線程在等待過程中被中斷或超時，或者屏障被重置，或者屏障的await方法被中斷，BrokenBarrierException或InterruptedException將會被拋出。這些異常需要被妥善處理，以確保程序的健壯性和正確性。
第6章：CyclicBarrier的高級用法
動態(tài)調整參與線程數
CyclicBarrier提供了一種機制，允許在運行時動態(tài)調整等待的線程數量。這在一些動態(tài)變化的并發(fā)場景中非常有用，比如線程數量會根據任務的不同而變化。
為了展示這個特性，小黑寫了以下的例子。在這個例子中，咱們會創(chuàng)建一個CyclicBarrier，并在運行時根據需要動態(tài)調整它的屏障點：
import java.util.concurrent.CyclicBarrier;
public class DynamicCyclicBarrierExample {
public static void main(String[] args) {
// 初始時，屏障點設置為3
CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("屏障點動作執(zhí)行"));
for (int i = 0; i < 2; i++) { // 初始只啟動兩個線程
new Thread(new Worker(barrier), "線程 " + i).start();
}
// 動態(tài)調整屏障點，現在需要4個線程到達屏障點
barrier.reset(); // 重置CyclicBarrier，這也會打破任何當前等待的線程
barrier = new CyclicBarrier(4, () -> System.out.println("新的屏障點動作執(zhí)行"));
for (int i = 0; i < 4; i++) { // 現在啟動四個線程
new Thread(new Worker(barrier), "線程 " + i).start();
}
}
static class Worker implements Runnable {
private final CyclicBarrier barrier;
Worker(CyclicBarrier barrier) {
this.barrier = barrier;
}
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " 到達屏障點");
barrier.await();
System.out.println(Thread.currentThread().getName() + " 繼續(xù)執(zhí)行");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}在這個例子中，咱們先創(chuàng)建了一個需要3個線程到達的CyclicBarrier。但后來因為需求變化，我們通過調用reset()方法重置了CyclicBarrier，并創(chuàng)建了一個新的CyclicBarrier，這次需要4個線程。這展示了如何根據實際情況調整同步點的數量。
結合其他并發(fā)工具使用
CyclicBarrier還可以與Java的其他并發(fā)工具一起使用，以解決更復雜的并發(fā)問題。例如，可以將其與ExecutorService結合使用，以管理線程池中的一組任務。
看看下面的例子，小黑展示了如何將CyclicBarrier與線程池結合使用：
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CyclicBarrierWithExecutorServiceExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(4);
CyclicBarrier barrier = new CyclicBarrier(4, () -> System.out.println("所有任務完成，準備下一輪執(zhí)行"));
for (int i = 0; i < 4; i++) {
executorService.execute(new Worker(barrier));
}
executorService.shutdown();
}
static class Worker implements Runnable {
private final CyclicBarrier barrier;
Worker(CyclicBarrier barrier) {
this.barrier = barrier;
}
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務");
Thread.sleep(1000);
barrier.await();
System.out.println(Thread.currentThread().getName() + " 任務完成");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}第7章：CyclicBarrier的問題和解決方案
1. BrokenBarrierException的處理
當參與CyclicBarrier的某個線程在等待期間被中斷，或者CyclicBarrier被重置，或者在屏障點等待的線程超時時，就會拋出BrokenBarrierException異常。這通常意味著CyclicBarrier無法正常工作。
解決這個問題的關鍵是要正確處理這個異常。咱們可以設置適當的異常處理邏輯，確保即使在出現異常時，程序也能以一種預期的方式繼續(xù)運行。例如，可以在捕獲到BrokenBarrierException時重置CyclicBarrier，或者采取其他恢復措施。
2. 超時的處理
如果咱們希望線程在等待達到屏障點的過程中不要無限期地等待，可以使用await(long timeout, TimeUnit unit)方法，為等待設置一個超時時間。如果在指定的時間內沒有所有的線程都到達屏障點，就會拋出TimeoutException。
處理超時的策略可能包括重試機制或者回退邏輯。但重要的是要確保所有的線程在超時后都能正確地處理這種情況，避免資源泄漏或者線程阻塞。
示例代碼：處理異常和超時
下面是一個示例，展示了如何在CyclicBarrier中處理BrokenBarrierException和超時異常：
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class CyclicBarrierExceptionHandlingExample {
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(3);
for (int i = 0; i < 3; i++) {
new Thread(new Task(barrier), "線程 " + i).start();
}
}
static class Task implements Runnable {
private final CyclicBarrier barrier;
Task(CyclicBarrier barrier) {
this.barrier = barrier;
}
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務");
Thread.sleep(1000);
System.out.println(Thread.currentThread().getName() + " 到達屏障點，等待其他線程");
barrier.await(2, TimeUnit.SECONDS); // 設置超時時間為2秒
} catch (InterruptedException e) {
System.out.println(Thread.currentThread().getName() + " 被中斷");
} catch (BrokenBarrierException e) {
System.out.println(Thread.currentThread().getName() + " 檢測到屏障損壞");
} catch (TimeoutException e) {
System.out.println(Thread.currentThread().getName() + " 等待超時");
}
System.out.println(Thread.currentThread().getName() + " 繼續(xù)執(zhí)行后續(xù)操作");
}
}
}在這個例子中，每個線程在執(zhí)行任務后會嘗試等待其他線程，但如果等待超過2秒，就會拋出TimeoutException。同時，這個代碼也演示了如何處理InterruptedException和BrokenBarrierException，確保線程在異常發(fā)生時能夠正確地繼續(xù)執(zhí)行。
3. CyclicBarrier重置問題
在使用CyclicBarrier時，還可能遇到需要重置屏障的情況。這可以通過調用reset()方法實現，但要注意這個操作會打破正在等待的線程。因此，在重置CyclicBarrier之前，需要確保所有線程都已經離開屏障點，或者咱們愿意接受打斷它們的等待過程。
總結
- 基本用法：CyclicBarrier主要用于協調多個線程，確保它們在繼續(xù)執(zhí)行之前在某個公共點同步。
- 重用性：一個CyclicBarrier可以被重復使用，這對于那些分階段執(zhí)行的多線程任務非常有用。
- 異常處理：正確處理
BrokenBarrierException和TimeoutException對于構建健壯的并發(fā)應用至關重要。 - 與其他工具的結合：CyclicBarrier可以與Java的其他并發(fā)工具，如ExecutorService，配合使用，以處理更復雜的并發(fā)場景。
學習并發(fā)編程是一個持續(xù)的過程。技術總是在發(fā)展，新的挑戰(zhàn)總是在出現。保持好奇心，不斷學習，小黑相信你會在這條路上越走越遠！
以上就是Java多線程之循環(huán)柵欄技術CyclicBarrier使用探索的詳細內容，更多關于Java多線程CyclicBarrier的資料請關注腳本之家其它相關文章！
相關文章
全面匯總SpringBoot和SpringClould常用注解
Java注解是附加在代碼中的一些元信息，用于一些工具在編譯、運行時進行解析和使用，起到說明、配置的功能,這篇文章就帶你來了解一下2021-08-08
MyBatis 是支持定制化 SQL、存儲過程以及高級映射的優(yōu)秀的持久層框架。MyBatis 避免了幾乎所有的 JDBC 代碼和手動設置參數以及獲取結果集，本文給大家介紹MyBatis 使用指南，一起看看吧2017-03-03
Java service層獲取HttpServletRequest工具類的方法
今天小編就為大家分享一篇關于Java service層獲取HttpServletRequest工具類的方法，小編覺得內容挺不錯的，現在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-12-12
下面小編就為大家?guī)硪黄狫ava基礎的幾道練習題(分享)。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧，希望可以幫到你2021-08-08
Spring Boot 3.x 集成 Eureka Server/Cl
隨著SpringBoot 3.x版本的開發(fā)嘗試,本文記錄了在集成Eureka Server/Client時所遇到的問題和解決方案,文中詳細介紹了搭建服務、配置文件和測試步驟,感興趣的朋友跟隨小編一起看看吧2024-09-09
那么有沒有一種辦法使得線程可以復用，就是執(zhí)行完一個任務，并不被銷毀，而是可以繼續(xù)執(zhí)行其他的任務？在Java中可以通過線程池來達到這樣的效果。下面我們來詳細了解一下吧2019-05-05
Maven項目部署到服務器設置訪問路徑以及配置虛擬目錄的方法
今天小編就為大家分享一篇關于Maven項目部署到服務器設置訪問路徑以及配置虛擬目錄的方法，小編覺得內容挺不錯的，現在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-02-02
在SpringBoot與Mybatis整合開發(fā)中,開啟控制臺SQL語句打印是一個常見需求,有助于調試與性能優(yōu)化,方法一：在Mybatis配置文件mybatis-config.xml中添加設置；方法二：在SpringBoot配置文件application.yml或properties中2024-11-11
Mybatis-plus中的@EnumValue注解使用詳解
這篇文章主要介紹了Mybatis-plus中的@EnumValue注解使用詳解,在PO類中,如果我們直接使用枚舉類型去映射數據庫的對應字段保存時,往往就會因為類型不匹配導致映射失敗,Mybatis-plus提供了一種解決辦法,就是使用@EnumValue注解,需要的朋友可以參考下2024-02-02
本篇文章主要介紹了Springboot整合RocketMQ使用心得，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-01-01