前言
最近在做一個原始成績統計的功能，用戶通過前臺設置相關參數，后臺實時統計并返回數據。相對來說統計功能點還是比較多的，這里大體羅列一下。
- 個人排名
- 本次測試的優良線、及格線、低分線
- 各個班級的排名人數(1-25、26-50 類比等等)
- 各個班級的前x名人數統計(前10、前20 類比等等)
- 各個班級的分數段學生人數統計(150-140、139-130 類比等等)
最好的用戶體驗，就是每一個操作都可以實時的展示數據，3秒之內應該是用戶的忍受范圍之內的了，所以做一款產品不僅要考慮用戶交互設計，后端的優化也是比不可少的。
大家可以簡單的看下以上這5項統計數據，總體來說，統計量還是不少的。最主要的還是要實時、實時、實時（重要的事情說三遍），顯然定時任務是不現實的。
改造前
程序邏輯
順序執行任務.png
改造后
程序邏輯
多任務并行處理.png
多任務并行處理，適用于多核cpu，單核cpu多線程執行任務可能會適得其反(上下文切換以及線程的創建和銷毀都會消耗資源)，特別是cpu密集型的任務。
代碼實現
statsdemo偽代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
/** * 多任務并行統計 * 創建者 科幫網 * 創建時間 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
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://blog.52itstyle.com/archives/2689/
