欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java 詳解循環(huán)屏障CyclicBarrier如何實(shí)現(xiàn)多線程分段等待執(zhí)行完成

 更新時間：2021年11月10日 11:12:27   作者：劍客阿良_ALiang  
CyclicBarrier是一個同步工具類，可以翻譯成循環(huán)屏障，也叫障礙器或同步屏障。CyclicBarrier內(nèi)部有一個計(jì)數(shù)器count，調(diào)用障礙器的await方法會使計(jì)數(shù)器count的值減一，當(dāng)計(jì)數(shù)器count的值為0時，表明調(diào)用了await方法線程已經(jīng)達(dá)到了設(shè)置的數(shù)量

前言

工作中是否有這樣的場景，多個線程任務(wù)，如果所有線程完成到某個階段，你希望知道所有線程均完成該階段。當(dāng)然你使用線程計(jì)數(shù)可以實(shí)現(xiàn)，只是不夠優(yōu)雅。

所以我即：Java 多線程等待優(yōu)雅的實(shí)現(xiàn)方式之Phaser同步屏障

之后再提供一個循環(huán)屏障，CyclicBarrier，更優(yōu)雅的實(shí)現(xiàn)工具。

Maven依賴

可以依賴，也可以不依賴，只是代碼要稍微多一些，最好添加。

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.7.15</version>
        </dependency>

代碼

不廢話，上代碼。

package com.huyi.csdn.tools;
 
import cn.hutool.core.thread.ThreadUtil;
import lombok.Getter;
import lombok.Setter;
 
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.*;
 
/**
 * @Program: csdn @ClassName: CyclicBarrierUtil @Author: huyi @Date: 2021-11-07 17:09 @Description:
 * 循環(huán)屏障工具 @Version: V1.0
 */
public class CyclicBarrierUtil {
  public static final ExecutorService executorService = Executors.newFixedThreadPool(50);
 
  @Getter
  @Setter
  public static class SegmentedTask {
    private Runnable start;
    private Runnable middle;
    private Runnable end;
 
    public SegmentedTask(Runnable start, Runnable middle, Runnable end) {
      this.start = start;
      this.middle = middle;
      this.end = end;
    }
  }
 
  /**
   * 提交任務(wù)
   *
   * @param tasks 參數(shù)
   */
  public static void submit(List<SegmentedTask> tasks) {
    CyclicBarrier cyclicBarrier = new CyclicBarrier(tasks.size() + 1);
    try {
      tasks.forEach(
          x -> {
            executorService.submit(
                () -> {
                  try {
                    x.getStart().run();
                    cyclicBarrier.await();
                    x.getMiddle().run();
                    cyclicBarrier.await();
                    x.getEnd().run();
                    cyclicBarrier.await();
                  } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                  }
                });
          });
      cyclicBarrier.await();
      System.out.println("初始任務(wù)已經(jīng)全部完成");
      cyclicBarrier.await();
      System.out.println("中間任務(wù)已經(jīng)全部完成");
      cyclicBarrier.await();
      System.out.println("最終任務(wù)已經(jīng)全部完成");
    } catch (InterruptedException | BrokenBarrierException e) {
      e.printStackTrace();
    }
  }
 
  public static void destroy() {
    System.out.println("摧毀線程池");
    executorService.shutdown();
  }
}

代碼說明

1、構(gòu)造了一個分段任務(wù)實(shí)體類，成員有3段Runnable。

2、不同段的Runnable完成后會等待其他線程完成該段任務(wù)。

驗(yàn)證代碼

  public static void main(String[] args) {
    Random random = new Random();
    List<SegmentedTask> tasks = new ArrayList<>();
    for (int i = 1; i < 11; i++) {
      int finalI = i;
      tasks.add(
          new SegmentedTask(
              () -> {
                ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
                System.out.println(
                    Thread.currentThread() + ":" + MessageFormat.format("第{0}軍團(tuán)已經(jīng)開始推進(jìn)！", finalI));
              },
              () -> {
                ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
                System.out.println(
                    Thread.currentThread() + ":" + MessageFormat.format("第{0}軍團(tuán)已經(jīng)正在進(jìn)攻！", finalI));
              },
              () -> {
                ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
                System.out.println(
                    Thread.currentThread() + ":" + MessageFormat.format("第{0}軍團(tuán)已經(jīng)攻陷陣地！", finalI));
              }));
    }
    CyclicBarrierUtil.submit(tasks);
    ThreadUtil.sleep(35, TimeUnit.SECONDS);
    CyclicBarrierUtil.destroy();
  }

驗(yàn)證結(jié)果

E:\Java\jdk1.8.0_40\bin\java.exe "-javaagent:E:\Program Files\JetBrains\IntelliJ IDEA 2020.1.1\lib\idea_rt.jar=5831:E:\Program Files\JetBrains\IntelliJ IDEA 2020.1.1\bin" -Dfile.encoding=UTF-8 -classpath E:\Java\jdk1.8.0_40\jre\lib\charsets.jar;E:\Java\jdk1.8.0_40\jre\lib\deploy.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\access-bridge-64.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\cldrdata.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\dnsns.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\jaccess.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\jfxrt.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\localedata.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\nashorn.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunec.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunjce_provider.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunmscapi.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunpkcs11.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\zipfs.jar;E:\Java\jdk1.8.0_40\jre\lib\javaws.jar;E:\Java\jdk1.8.0_40\jre\lib\jce.jar;E:\Java\jdk1.8.0_40\jre\lib\jfr.jar;E:\Java\jdk1.8.0_40\jre\lib\jfxswt.jar;E:\Java\jdk1.8.0_40\jre\lib\jsse.jar;E:\Java\jdk1.8.0_40\jre\lib\management-agent.jar;E:\Java\jdk1.8.0_40\jre\lib\plugin.jar;E:\Java\jdk1.8.0_40\jre\lib\resources.jar;E:\Java\jdk1.8.0_40\jre\lib\rt.jar;C:\Users\yi\IdeaProjects\csdn\target\classes;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-web\2.5.6\spring-boot-starter-web-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter\2.5.6\spring-boot-starter-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-logging\2.5.6\spring-boot-starter-logging-2.5.6.jar;C:\Users\yi\.m2\repository\ch\qos\logback\logback-classic\1.2.6\logback-classic-1.2.6.jar;C:\Users\yi\.m2\repository\ch\qos\logback\logback-core\1.2.6\logback-core-1.2.6.jar;C:\Users\yi\.m2\repository\org\apache\logging\log4j\log4j-to-slf4j\2.14.1\log4j-to-slf4j-2.14.1.jar;C:\Users\yi\.m2\repository\org\apache\logging\log4j\log4j-api\2.14.1\log4j-api-2.14.1.jar;C:\Users\yi\.m2\repository\org\slf4j\jul-to-slf4j\1.7.32\jul-to-slf4j-1.7.32.jar;C:\Users\yi\.m2\repository\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;C:\Users\yi\.m2\repository\org\yaml\snakeyaml\1.28\snakeyaml-1.28.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-json\2.5.6\spring-boot-starter-json-2.5.6.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.12.5\jackson-databind-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.12.5\jackson-annotations-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.12.5\jackson-core-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.12.5\jackson-datatype-jdk8-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.12.5\jackson-datatype-jsr310-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\module\jackson-module-parameter-names\2.12.5\jackson-module-parameter-names-2.12.5.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-tomcat\2.5.6\spring-boot-starter-tomcat-2.5.6.jar;C:\Users\yi\.m2\repository\org\apache\tomcat\embed\tomcat-embed-core\9.0.54\tomcat-embed-core-9.0.54.jar;C:\Users\yi\.m2\repository\org\apache\tomcat\embed\tomcat-embed-el\9.0.54\tomcat-embed-el-9.0.54.jar;C:\Users\yi\.m2\repository\org\apache\tomcat\embed\tomcat-embed-websocket\9.0.54\tomcat-embed-websocket-9.0.54.jar;C:\Users\yi\.m2\repository\org\springframework\spring-web\5.3.12\spring-web-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-beans\5.3.12\spring-beans-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-webmvc\5.3.12\spring-webmvc-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-aop\5.3.12\spring-aop-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-context\5.3.12\spring-context-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-expression\5.3.12\spring-expression-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-devtools\2.5.6\spring-boot-devtools-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot\2.5.6\spring-boot-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-autoconfigure\2.5.6\spring-boot-autoconfigure-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-configuration-processor\2.5.6\spring-boot-configuration-processor-2.5.6.jar;C:\Users\yi\.m2\repository\org\projectlombok\lombok\1.18.22\lombok-1.18.22.jar;C:\Users\yi\.m2\repository\org\slf4j\slf4j-api\1.7.32\slf4j-api-1.7.32.jar;C:\Users\yi\.m2\repository\org\springframework\spring-core\5.3.12\spring-core-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-jcl\5.3.12\spring-jcl-5.3.12.jar;C:\Users\yi\.m2\repository\cn\hutool\hutool-all\5.7.15\hutool-all-5.7.15.jar;C:\Users\yi\.m2\repository\com\google\guava\guava\31.0.1-jre\guava-31.0.1-jre.jar;C:\Users\yi\.m2\repository\com\google\guava\failureaccess\1.0.1\failureaccess-1.0.1.jar;C:\Users\yi\.m2\repository\com\google\guava\listenablefuture\9999.0-empty-to-avoid-conflict-with-guava\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar;C:\Users\yi\.m2\repository\com\google\code\findbugs\jsr305\3.0.2\jsr305-3.0.2.jar;C:\Users\yi\.m2\repository\org\checkerframework\checker-qual\3.12.0\checker-qual-3.12.0.jar;C:\Users\yi\.m2\repository\com\google\errorprone\error_prone_annotations\2.7.1\error_prone_annotations-2.7.1.jar;C:\Users\yi\.m2\repository\com\google\j2objc\j2objc-annotations\1.3\j2objc-annotations-1.3.jar com.huyi.csdn.tools.CyclicBarrierUtil
Thread[pool-1-thread-9,5,main]:第9軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-10,5,main]:第10軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-8,5,main]:第8軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-3,5,main]:第3軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-7,5,main]:第7軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-5,5,main]:第5軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-6,5,main]:第6軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-4,5,main]:第4軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-1,5,main]:第1軍團(tuán)已經(jīng)開始推進(jìn)！
Thread[pool-1-thread-2,5,main]:第2軍團(tuán)已經(jīng)開始推進(jìn)！
初始任務(wù)已經(jīng)全部完成
Thread[pool-1-thread-4,5,main]:第4軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-6,5,main]:第6軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-5,5,main]:第5軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-8,5,main]:第8軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-7,5,main]:第7軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-9,5,main]:第9軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-1,5,main]:第1軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-2,5,main]:第2軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-3,5,main]:第3軍團(tuán)已經(jīng)正在進(jìn)攻！
Thread[pool-1-thread-10,5,main]:第10軍團(tuán)已經(jīng)正在進(jìn)攻！
中間任務(wù)已經(jīng)全部完成
Thread[pool-1-thread-7,5,main]:第7軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-5,5,main]:第5軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-2,5,main]:第2軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-8,5,main]:第8軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-3,5,main]:第3軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-9,5,main]:第9軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-10,5,main]:第10軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-4,5,main]:第4軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-1,5,main]:第1軍團(tuán)已經(jīng)攻陷陣地！
Thread[pool-1-thread-6,5,main]:第6軍團(tuán)已經(jīng)攻陷陣地！
最終任務(wù)已經(jīng)全部完成
摧毀線程池

Process finished with exit code 0

OK，完美。

總結(jié)

該工具中的分段任務(wù)實(shí)體可以調(diào)整，按照你的需求來。該工具類就是給個模板，供參考用。

最近很多事情不是很順，天氣也轉(zhuǎn)涼了，下了一天的雨。但想到冬天懶懶的陽光，會不經(jīng)意的伸個懶腰，陽光總會來的。

分享：

此生來生都愿識盡世間好人，讀盡世間好書，看盡世間好山水，天上風(fēng)景再好，從不羨慕。---《雪中悍刀行》

如果本文對你有幫助的話，不要吝嗇你的贊，謝謝。

以上就是Java 詳解循環(huán)屏障CyclicBarrier如何實(shí)現(xiàn)多線程分段等待執(zhí)行完成的詳細(xì)內(nèi)容，更多關(guān)于Java 循環(huán)屏障 CyclicBarrier的資料請關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

  • 詳解IDEA2020新建spring項(xiàng)目和c3p0連接池的創(chuàng)建和使用

    詳解IDEA2020新建spring項(xiàng)目和c3p0連接池的創(chuàng)建和使用

    C3P0是一個開源的JDBC連接池，它實(shí)現(xiàn)了數(shù)據(jù)源和JNDI綁定，本文就使用Spring實(shí)現(xiàn)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2021-08-08
  • spring?Cloud微服務(wù)阿里開源TTL身份信息的線程間復(fù)用

    spring?Cloud微服務(wù)阿里開源TTL身份信息的線程間復(fù)用

    這篇文章主要為大家介紹了spring?Cloud微服務(wù)中使用阿里開源TTL身份信息的線程間復(fù)用,有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
    2023-01-01
  • Java日常練習(xí)題,每天進(jìn)步一點(diǎn)點(diǎn)(19)

    Java日常練習(xí)題,每天進(jìn)步一點(diǎn)點(diǎn)(19)

    下面小編就為大家?guī)硪黄狫ava基礎(chǔ)的幾道練習(xí)題(分享)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧，希望可以幫到你
    2021-07-07
  • 利用Java實(shí)現(xiàn)紅黑樹

    利用Java實(shí)現(xiàn)紅黑樹

    紅黑樹是眾多“平衡的”搜索樹模式中的一種，在最壞情況下，它相關(guān)操作的時間復(fù)雜度為O(log n)，接下倆小編將子啊下文詳細(xì)介紹Java是如何實(shí)現(xiàn)紅黑樹的
    2021-09-09
  • SpringBoot RestTemplate GET POST請求的實(shí)例講解

    SpringBoot RestTemplate GET POST請求的實(shí)例講解

    這篇文章主要介紹了SpringBoot RestTemplate GET POST請求的實(shí)例講解，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-09-09
  • Tornadofx學(xué)習(xí)筆記之IconTextFx開源庫整合5000+個字體圖標(biāo)

    Tornadofx學(xué)習(xí)筆記之IconTextFx開源庫整合5000+個字體圖標(biāo)

    這篇文章主要介紹了Tornadofx學(xué)習(xí)筆記之IconTextFx開源庫整合5000+個字體圖標(biāo)的相關(guān)知識,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
    2021-12-12
  • SpringBoot整合MongoDB實(shí)現(xiàn)文件上傳下載刪除

    SpringBoot整合MongoDB實(shí)現(xiàn)文件上傳下載刪除

    這篇文章主要介紹了SpringBoot整合MongoDB實(shí)現(xiàn)文件上傳下載刪除的方法，幫助大家更好的理解和學(xué)習(xí)使用SpringBoot框架，感興趣的朋友可以了解下
    2021-05-05
  • Spring零基礎(chǔ)入門WebFlux響應(yīng)式編程

    Spring零基礎(chǔ)入門WebFlux響應(yīng)式編程

    Spring 提供了兩個并行堆棧，一種是基于帶有 Spring MVC 和 Spring Data 結(jié)構(gòu)的 Servlet API，另一個是完全反應(yīng)式堆棧，它利用了 Spring WebFlux 和 Spring Data 的反應(yīng)式存儲庫，這篇文章主要介紹了Spring-webflux 響應(yīng)式編程,需要的朋友可以參考下
    2022-10-10
  • Java編寫實(shí)現(xiàn)窗體程序顯示日歷

    Java編寫實(shí)現(xiàn)窗體程序顯示日歷

    這篇文章主要為大家詳細(xì)介紹了Java編寫實(shí)現(xiàn)窗體程序顯示日歷，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2022-06-06
  • springboot中的starter使用解析

    springboot中的starter使用解析

    這篇文章主要介紹了springboot中的starter使用解析,引入了starter依賴之后,基礎(chǔ)組件就可以像在spring的bean一樣在項(xiàng)目中使用,那其實(shí)只要找到在哪里加載了這些bean就明白了,需要的朋友可以參考下
    2023-10-10

最新評論