前言

成都創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),合浦企業(yè)網(wǎng)站建設(shè),合浦品牌網(wǎng)站建設(shè),網(wǎng)站定制,合浦網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷(xiāo),網(wǎng)絡(luò)優(yōu)化,合浦網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。

最近在做一個(gè)原始成績(jī)統(tǒng)計(jì)的功能，用戶通過(guò)前臺(tái)設(shè)置相關(guān)參數(shù)，后臺(tái)實(shí)時(shí)統(tǒng)計(jì)并返回?cái)?shù)據(jù)。相對(duì)來(lái)說(shuō)統(tǒng)計(jì)功能點(diǎn)還是比較多的，這里大體羅列一下。

1. 個(gè)人排名
2. 本次測(cè)試的優(yōu)良線、及格線、低分線
3. 各個(gè)班級(jí)的排名人數(shù)(1-25、26-50 類比等等)
4. 各個(gè)班級(jí)的前X名人數(shù)統(tǒng)計(jì)(前10、前20 類比等等)
5. 各個(gè)班級(jí)的分?jǐn)?shù)段學(xué)生人數(shù)統(tǒng)計(jì)(150-140、139-130 類比等等)

最好的用戶體驗(yàn)，就是每一個(gè)操作都可以實(shí)時(shí)的展示數(shù)據(jù)，3秒之內(nèi)應(yīng)該是用戶的忍受范圍之內(nèi)的了，所以做一款產(chǎn)品不僅要考慮用戶交互設(shè)計(jì)，后端的優(yōu)化也是比不可少的。

大家可以簡(jiǎn)單的看下以上這5項(xiàng)統(tǒng)計(jì)數(shù)據(jù)，總體來(lái)說(shuō)，統(tǒng)計(jì)量還是不少的。最主要的還是要實(shí)時(shí)、實(shí)時(shí)、實(shí)時(shí)（重要的事情說(shuō)三遍），顯然定時(shí)任務(wù)是不現(xiàn)實(shí)的。

改造前

程序邏輯

順序執(zhí)行任務(wù).png

改造后

程序邏輯

多任務(wù)并行處理.png

多任務(wù)并行處理，適用于多核CPU，單核CPU多線程執(zhí)行任務(wù)可能會(huì)適得其反(上下文切換以及線程的創(chuàng)建和銷(xiāo)毀都會(huì)消耗資源)，特別是CPU密集型的任務(wù)。

代碼實(shí)現(xiàn)

StatsDemo偽代碼：

/**
 * 多任務(wù)并行統(tǒng)計(jì)
 * 創(chuàng)建者 科幫網(wǎng)
 * 創(chuàng)建時(shí)間  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);// 兩個(gè)賽跑者
    Stats stats1 = new Stats("任務(wù)A", 1000, latch);
    Stats stats2 = new Stats("任務(wù)B", 2000, latch);
    Stats stats3 = new Stats("任務(wù)C", 2000, latch);
    Stats stats4 = new Stats("任務(wù)D", 2000, latch);
    Stats stats5 = new Stats("任務(wù)E", 2000, latch);
    stats1.start();//任務(wù)A開(kāi)始執(zhí)行
    stats2.start();//任務(wù)B開(kāi)始執(zhí)行
    stats3.start();//任務(wù)C開(kāi)始執(zhí)行
    stats4.start();//任務(wù)D開(kāi)始執(zhí)行
    stats5.start();//任務(wù)E開(kāi)始執(zhí)行
    latch.await();// 等待所有人任務(wù)結(jié)束
    System.out.println("所有的統(tǒng)計(jì)任務(wù)執(zhí)行完成:" + 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);
        //模擬任務(wù)執(zhí)行時(shí)間
        Thread.sleep(runTime);
        System.out.println(statsName + " do stats complete at "+ sdf.format(new Date()));
        latch.countDown();//單次任務(wù)結(jié)束，計(jì)數(shù)器減一
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
}

由于要同步返回統(tǒng)計(jì)數(shù)據(jù)，這里我們使用到了CountDownLatch類，它是Java5中新增的一個(gè)并發(fā)工具類，其使用非常簡(jiǎn)單，參考上面的偽代碼給出了詳細(xì)的使用步驟。

CountDownLatch用于同步一個(gè)或多個(gè)任務(wù)，強(qiáng)制他們等待由其他任務(wù)執(zhí)行的一組操作完成。CountDownLatch典型的用法是將一個(gè)程序分為N個(gè)互相獨(dú)立的可解決任務(wù)，并創(chuàng)建值為N的CountDownLatch。當(dāng)每一個(gè)任務(wù)完成時(shí)，都會(huì)在這個(gè)鎖存器上調(diào)用countDown，等待問(wèn)題被解決的任務(wù)調(diào)用這個(gè)鎖存器的await，將他們自己攔住，直至鎖存器計(jì)數(shù)結(jié)束。

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

項(xiàng)目源碼：https://gitee.com/52itstyle/spring-data-jpa

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。