亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

SpringBoot CountDownLatch多任務并行處理的實現方法

發布時間:2020-09-10 09:37:34 來源:腳本之家 閱讀:269 作者:小柒 欄目:編程語言

前言

最近在做一個原始成績統計的功能,用戶通過前臺設置相關參數,后臺實時統計并返回數據。相對來說統計功能點還是比較多的,這里大體羅列一下。

  1. 個人排名
  2. 本次測試的優良線、及格線、低分線
  3. 各個班級的排名人數(1-25、26-50 類比等等)
  4. 各個班級的前X名人數統計(前10、前20 類比等等)
  5. 各個班級的分數段學生人數統計(150-140、139-130 類比等等)

最好的用戶體驗,就是每一個操作都可以實時的展示數據,3秒之內應該是用戶的忍受范圍之內的了,所以做一款產品不僅要考慮用戶交互設計,后端的優化也是比不可少的。

大家可以簡單的看下以上這5項統計數據,總體來說,統計量還是不少的。最主要的還是要實時、實時、實時(重要的事情說三遍),顯然定時任務是不現實的。

改造前

程序邏輯

SpringBoot CountDownLatch多任務并行處理的實現方法

順序執行任務.png

改造后

程序邏輯

SpringBoot CountDownLatch多任務并行處理的實現方法

多任務并行處理.png

多任務并行處理,適用于多核CPU,單核CPU多線程執行任務可能會適得其反(上下文切換以及線程的創建和銷毀都會消耗資源),特別是CPU密集型的任務。

代碼實現

StatsDemo偽代碼:

/**
 * 多任務并行統計
 * 創建者 科幫網
 * 創建時間  2018年4月16日
 */
public class StatsDemo {
  final static SimpleDateFormat sdf = new SimpleDateFormat(
      "yyyy-MM-dd HH:mm:ss");
  
  final static String startTime = sdf.format(new Date());

  public static void main(String[] args) throws InterruptedException {
    CountDownLatch latch = new CountDownLatch(5);// 兩個賽跑者
    Stats stats1 = new Stats("任務A", 1000, latch);
    Stats stats2 = new Stats("任務B", 2000, latch);
    Stats stats3 = new Stats("任務C", 2000, latch);
    Stats stats4 = new Stats("任務D", 2000, latch);
    Stats stats5 = new Stats("任務E", 2000, latch);
    stats1.start();//任務A開始執行
    stats2.start();//任務B開始執行
    stats3.start();//任務C開始執行
    stats4.start();//任務D開始執行
    stats5.start();//任務E開始執行
    latch.await();// 等待所有人任務結束
    System.out.println("所有的統計任務執行完成:" + sdf.format(new Date()));
  }

  static class Stats extends Thread {
    String statsName;
    int runTime;
    CountDownLatch latch;

    public Stats(String statsName, int runTime, CountDownLatch latch) {
      this.statsName = statsName;
      this.runTime = runTime;
      this.latch = latch;
    }

    public void run() {
      try {
        System.out.println(statsName+ " do stats begin at "+ startTime);
        //模擬任務執行時間
        Thread.sleep(runTime);
        System.out.println(statsName + " do stats complete at "+ sdf.format(new Date()));
        latch.countDown();//單次任務結束,計數器減一
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
}

由于要同步返回統計數據,這里我們使用到了CountDownLatch類,它是Java5中新增的一個并發工具類,其使用非常簡單,參考上面的偽代碼給出了詳細的使用步驟。

CountDownLatch用于同步一個或多個任務,強制他們等待由其他任務執行的一組操作完成。CountDownLatch典型的用法是將一個程序分為N個互相獨立的可解決任務,并創建值為N的CountDownLatch。當每一個任務完成時,都會在這個鎖存器上調用countDown,等待問題被解決的任務調用這個鎖存器的await,將他們自己攔住,直至鎖存器計數結束。

具體的源碼解讀,大家可以參考: 源碼分析之CountDownLatch

項目源碼:https://gitee.com/52itstyle/spring-data-jpa

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

滕州市| 武安市| 南川市| 甘泉县| 崇礼县| 剑川县| 郓城县| 虎林市| 岢岚县| 南召县| 克拉玛依市| 太仆寺旗| 武邑县| 阳朔县| 临西县| 建始县| 永宁县| 绥棱县| 和平县| 乐都县| 法库县| 兰考县| 喜德县| 武宣县| 通城县| 利辛县| 讷河市| 陵川县| 鄂托克旗| 新宁县| 荥阳市| 尖扎县| 连江县| 昆山市| 兴城市| 容城县| 万山特区| 鹤山市| 德令哈市| 肇源县| 牡丹江市|