javascript
SpringBoot开发案例之CountDownLatch多任务并行处理
前言
最近在做一個原始成績統計的功能,用戶通過前臺設置相關參數,后臺實時統計并返回數據。相對來說統計功能點還是比較多的,這里大體羅列一下。
- 個人排名
- 本次測試的優良線、及格線、低分線
- 各個班級的排名人數(1-25、26-50 類比等等)
- 各個班級的前X名人數統計(前10、前20 類比等等)
- 各個班級的分數段學生人數統計(150-140、139-130 類比等等)
最好的用戶體驗,就是每一個操作都可以實時的展示數據,3秒之內應該是用戶的忍受范圍之內的了,所以做一款產品不僅要考慮用戶交互設計,后端的優化也是比不可少的。
大家可以簡單的看下以上這5項統計數據,總體來說,統計量還是不少的。最主要的還是要實時、實時、實時(重要的事情說三遍),顯然定時任務是不現實的。
改造前
程序邏輯
改造后
程序邏輯
代碼實現
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,將他們自己攔住,直至鎖存器計數結束。
具體的源碼解讀,大家可以參考:【JUC】JDK1.8源碼分析之CountDownLatch
項目源碼:https://gitee.com/52itstyle/spring-data-jpa
作者: 小柒2012
歡迎關注: https://blog.52itstyle.com
總結
以上是生活随笔為你收集整理的SpringBoot开发案例之CountDownLatch多任务并行处理的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 今日水印相机如何改时间地点(今日热榜官网
- 下一篇: 天龙八部荣耀版积分商店在哪里