多線程使用不當(dāng)導(dǎo)致的 OOM

程序員的成長(zhǎng)之路

互聯(lián)網(wǎng)/程序員/技術(shù)/資料共享 

來自：juejin.cn/post/7064376361334358046

事故描述

整體經(jīng)過

事故根本原因

public static void test() throws InterruptedException, ExecutionException {

    Executor executor = Executors.newFixedThreadPool(3);
    CompletionService<String> service = new ExecutorCompletionService<>(executor);
        service.submit(new Callable<String>() {
            @Override
            public String call() throws Exception {
                return "HelloWorld--" + Thread.currentThread().getName();
            }
        });
}

public static void test() throws InterruptedException, ExecutionException {
    Executor executor = Executors.newFixedThreadPool(3);
    CompletionService<String> service = new ExecutorCompletionService<>(executor);
    service.submit(new Callable<String>() {
        @Override
        public String call() throws Exception {
            return "HelloWorld--" + Thread.currentThread().getName();
        }
    });
    service.take().get();
}

探尋問題根源

public static void test1() throws Exception{
    ExecutorService executorService = Executors.newCachedThreadPool();
    ArrayList<Future<String>> futureArrayList = new ArrayList<>();
    System.out.println("公司讓你通知大家聚餐 你開車去接人");
    Future<String> future10 = executorService.submit(() -> {
        System.out.println("總裁：我在家上大號(hào) 我最近拉肚子比較慢 要蹲1個(gè)小時(shí)才能出來 你等會(huì)來接我吧");
        TimeUnit.SECONDS.sleep(10);
        System.out.println("總裁：1小時(shí)了 我上完大號(hào)了。你來接吧");
        return "總裁上完大號(hào)了";
    });
    futureArrayList.add(future10);
    Future<String> future3 = executorService.submit(() -> {
        System.out.println("研發(fā)：我在家上大號(hào) 我比較快 要蹲3分鐘就可以出來 你等會(huì)來接我吧");
        TimeUnit.SECONDS.sleep(3);
        System.out.println("研發(fā)：3分鐘 我上完大號(hào)了。你來接吧");
        return "研發(fā)上完大號(hào)了";
    });
    futureArrayList.add(future3);
    Future<String> future6 = executorService.submit(() -> {
        System.out.println("中層管理：我在家上大號(hào)  要蹲10分鐘就可以出來 你等會(huì)來接我吧");
        TimeUnit.SECONDS.sleep(6);
        System.out.println("中層管理：10分鐘 我上完大號(hào)了。你來接吧");
        return "中層管理上完大號(hào)了";
    });
    futureArrayList.add(future6);
    TimeUnit.SECONDS.sleep(1);
    System.out.println("都通知完了,等著接吧。");
    try {
        for (Future<String> future : futureArrayList) {
            String returnStr = future.get();
            System.out.println(returnStr + "，你去接他");
        }
        Thread.currentThread().join();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

• 第一步：主線程把三個(gè)任務(wù)提交到線程池里面去，把對(duì)應(yīng)返回的 Future 放到 List 里面存起來，然后執(zhí)行“都通知完了,等著接吧。”這行輸出語句；

• 第二步：在循環(huán)里面執(zhí)行 future.get() 操作，阻塞等待。

public static void test2() throws Exception {
    ExecutorService executorService = Executors.newCachedThreadPool();
    ExecutorCompletionService<String> completionService = new ExecutorCompletionService<>(executorService);
    System.out.println("公司讓你通知大家聚餐 你開車去接人");
    completionService.submit(() -> {
        System.out.println("總裁：我在家上大號(hào) 我最近拉肚子比較慢 要蹲1個(gè)小時(shí)才能出來 你等會(huì)來接我吧");
        TimeUnit.SECONDS.sleep(10);
        System.out.println("總裁：1小時(shí)了 我上完大號(hào)了。你來接吧");
        return "總裁上完大號(hào)了";
    });
    completionService.submit(() -> {
        System.out.println("研發(fā)：我在家上大號(hào) 我比較快 要蹲3分鐘就可以出來 你等會(huì)來接我吧");
        TimeUnit.SECONDS.sleep(3);
        System.out.println("研發(fā)：3分鐘 我上完大號(hào)了。你來接吧");
        return "研發(fā)上完大號(hào)了";
    });
    completionService.submit(() -> {
        System.out.println("中層管理：我在家上大號(hào)  要蹲10分鐘就可以出來 你等會(huì)來接我吧");
        TimeUnit.SECONDS.sleep(6);
        System.out.println("中層管理：10分鐘 我上完大號(hào)了。你來接吧");
        return "中層管理上完大號(hào)了";
    });
    TimeUnit.SECONDS.sleep(1);
    System.out.println("都通知完了,等著接吧。");
    //提交了3個(gè)異步任務(wù)）
    for (int i = 0; i < 3; i++) {
        String returnStr = completionService.take().get();
        System.out.println(returnStr + "，你去接他");
    }
    Thread.currentThread().join();
}

completionService.take().get();

1、ExecutorCompletionService 是 CompletionService 接口的實(shí)現(xiàn)類

2、接著跟一下 ExecutorCompletionService 的構(gòu)造方法。

3、Submit 任務(wù)提交的兩種方式，都是有返回值的，我們例子中用到的就是第一種 Callable 類型的方法。

4、對(duì)比ExecutorService 和 ExecutorCompletionService 的 submit 方法可以看出區(qū)別。

5、差異就在 QueueingFuture。

• QueueingFuture 繼承自 FutureTask，而且紅線部分標(biāo)注的位置，重寫了 done() 方法；

• 把 task 放到 completionQueue 隊(duì)列里面。當(dāng)任務(wù)執(zhí)行完成后，task 就會(huì)被放到隊(duì)列里面去了；

• 此時(shí)此刻，completionQueue 隊(duì)列里面的 task 都是已經(jīng) done() 完成了的 task。而這個(gè) task 就是我們拿到的一個(gè)個(gè)的 future 結(jié)果；

• 如果調(diào)用 completionQueue 的 task 方法，會(huì)阻塞等待任務(wù)。等到的一定是完成了的 future，我們調(diào)用  .get() 方法 就能立馬獲得結(jié)果。

• 我們?cè)谑褂?nbsp;ExecutorService submit 提交任務(wù)后需要關(guān)注每個(gè)任務(wù)返回的 future。然而 CompletionService 對(duì)這些 future 進(jìn)行了追蹤，并且重寫了 done 方法，讓你等的 completionQueue 隊(duì)列里面一定是完成了的 task；

• 作為網(wǎng)關(guān) RPC 層，我們不用因?yàn)槟骋粋€(gè)接口的響應(yīng)慢拖累所有的請(qǐng)求，可以在處理最快響應(yīng)的業(yè)務(wù)場(chǎng)景里使用 CompletionService。

但是請(qǐng)注意！也是本次事故的核心問題。

總結(jié)

上線前

• 嚴(yán)格的代碼 review 習(xí)慣，一定要交給 back 人去看，畢竟自己寫的代碼自己是看不出問題的，相信每個(gè)程序猿都有這個(gè)自信；

• 上線記錄：備注好上一個(gè)可回滾的包版本（給自己留一個(gè)后路）；

• 上線前確認(rèn)回滾后，業(yè)務(wù)是否可降級(jí)。如果不可降級(jí)，一定要嚴(yán)格拉長(zhǎng)這次上線的監(jiān)控周期。

上線后

• 持續(xù)關(guān)注內(nèi)存增長(zhǎng)情況（這部分極容易被忽略，大家對(duì)內(nèi)存的重視度不如 CPU 使用率）；

• 持續(xù)關(guān)注 CPU 使用率增長(zhǎng)情況

• GC 情況、線程數(shù)是否增長(zhǎng)、是否有頻繁的 Full GC 等；

• 關(guān)注服務(wù)性能報(bào)警，TP99、999 、MAX 是否出現(xiàn)明顯的增高。

互聯(lián)網(wǎng)初中高級(jí)大廠面試題(9個(gè)G)
內(nèi)容包含Java基礎(chǔ)、JavaWeb、MySQL性能優(yōu)化、JVM、鎖、百萬并發(fā)、消息隊(duì)列、高性能緩存、反射、Spring全家桶原理、微服務(wù)、Zookeeper......等技術(shù)棧！
?戳閱讀原文領(lǐng)取！                                  朕已閱