Java併發面試，幸好有點道行，否則又被忽悠了

時間 2019-12-01

標籤 java 併發面試幸好有點道行否則又被忽悠欄目 Java 简体版

原文原文鏈接

前言

面試Java，必然要被問Java內存模型和Java併發開發。我被問到的時候，內心慌得一批，「額，是在《Thinking in Java》裏面寫的嗎？果真天天增刪改太low了」面試

要了解這些圖嗎？

我但願能解釋的再簡單一些，以上都不用

Java 併發代碼

public class Example1 {
    public static int count = 0;
    public static int clientTotal = 5000;
    public static void main(String[] args) throws Exception {
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < clientTotal ; i++) {
            executorService.execute(() -> {
                try {
                    add();
                } catch (Exception e) {
                    log.error("exception", e);
                }
            });
        }
    }
    private static void add() {
        count++;
    }
}

複製代碼

若是上面代碼執行，count的值是多少？（爲了說明重點問題，沒有寫最後打印的代碼） 5000？屢次運行的結果，count的值是小於5000的。shell

解釋一下上面的程序，首先定義了一個線程池，啓動5000個線程執行add()操做，add函數處理靜態成員變量count。bash

若是程序順序調用，count的值應該是5000。多線程

for(int i=0;i<5000;i++){
    add();
}

複製代碼

可是線程池啓動多線程，是併發執行的。每一個線程啓動以後，無論是否運行結束，下一個線程會立刻啓動。併發

啓動線程的過程，是一個異步過程，啓動線程當即返回，啓動下一個進程。

當多個線程對同一個變量add進行操做的時候，就會發生寫寫衝突。框架

線程一、線程2 同時對值爲0的變量進行操做，結果返回1，而不是2。若是這個地方想不明白，就請留言，或者看看文章頂部那些原理圖。異步

要不簡單點，記住「多線程對全局變量的寫操做會發生衝突」。

答案，聲明原子變量 AtomicInteger count

public class CountExample2 {

    // 請求總數
    public static int clientTotal = 5000;

    // 同時併發執行的線程數
    public static int threadTotal = 200;

    public static AtomicInteger count = new AtomicInteger(0);

    public static void main(String[] args) throws Exception {
        ExecutorService executorService = Executors.newCachedThreadPool();
        final Semaphore semaphore = new Semaphore(threadTotal);
        final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);
        for (int i = 0; i < clientTotal ; i++) {
            executorService.execute(() -> {
                try {
                    semaphore.acquire();
                    add();
                    semaphore.release();
                } catch (Exception e) {
                    log.error("exception", e);
                }
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        log.info("count:{}", count.get());
    }
    private static void add() {
        count.incrementAndGet();
        // count.getAndIncrement();
    }
}

複製代碼

注，上面的代碼用了生成者消費者模式，5000個生產者，200個消費者，對程序併發作必定限制，防止5000個線程卡死計算機。函數