java非同步任務處理
阿新 • • 發佈:2019-01-03
幫助理解非同步的小程式
原文地址:https://www.cnblogs.com/chenmo-xpw/p/5652029.html
1、場景
最近做專案的時候遇到了一個小問題:從前臺提交到服務端A,A呼叫服務端B處理超時,原因是前端一次請求往db插1萬資料,插完之後會去清理快取、傳送訊息。
服務端的有三個操作 a、插DB b、清理cache c、傳送訊息。1萬條資料,說多不多,說少不少.況且不是單單insert。出現超時現象,不足為奇了吧~~
2、分析
如何避免超時呢?一次請求處理辣麼多資料,可分多次請求處理,每次請求處理100條資料,可以有效解決超時問題. 為了不影響使用者的體驗,請求改為ajax 非同步請求。
除此之外,仔細分析下場景. a 操作是本次處理的核心. 而b、c操作可以非同步處理。換句話說,a操作處理完可以馬上返回給結果, 不必等b、c處理完再返回。b、c操作可以放在一個非同步任務去處理。
3、實戰
(1)、ExecutorService : 任務提交
(2)、demo
非同步任務類
public class ExecutorDemo { private ExecutorService executor = Executors.newFixedThreadPool(1);public void asynTask() throws InterruptedException { executor.submit(new Runnable() { @Override public void run() { try { Thread.sleep(10000);//方便觀察結果 } catch (InterruptedException e) { e.printStackTrace(); }int sum = 0; for(int i = 0; i < 1000; i++) { sum += i; } System.out.println(sum); } }); } }
客戶端模擬
public class Client { public static void main(String[] args) throws InterruptedException { boolean r = task2(); if(r) { task3(); } System.out.println("------------main end-----------"); } static boolean task2() throws InterruptedException { ExecutorDemo e = new ExecutorDemo(); e.asynTask(); System.out.println("------------task2 end-----------"); return true; } static void task3() throws InterruptedException { int j = 0; while(true) { if(j++ > 10000) { break; } } System.out.println("------------task3 end-----------"); } }
結果是醬紫的
------------task2 end----------- ------------task3 end----------- ------------main end----------- 499500