面試Java,必然要被問Java內存模型和Java併發開發。我被問到的時候,內心慌得一批,「額,是在《Thinking in Java》裏面寫的嗎?果真天天增刪改太low了」面試
Java 併發代碼shell
複製代碼
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的。bash
解釋一下上面的程序,首先定義了一個線程池,啓動5000個線程執行add()操做,add函數處理靜態成員變量count。多線程
若是程序順序調用,count的值應該是5000。併發
複製代碼
for(int i=0;i<5000;i++){
add();
}
可是線程池啓動多線程,是併發執行的。每一個線程啓動以後,無論是否運行結束,下一個線程會立刻啓動。異步
啓動線程的過程,是一個異步過程,啓動線程當即返回,啓動下一個進程。函數
當多個線程對同一個變量add進行操做的時候,就會發生寫寫衝突。ui
線程一、線程2 同時對值爲0的變量進行操做,結果返回1,而不是2。若是這個地方想不明白,就請留言,或者看看文章頂部那些原理圖。spa
要不簡單點,記住「多線程對全局變量的寫操做會發生衝突」。線程
複製代碼
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個線程卡死計算機。
這個就是C的內存模型,作shellcode的基礎知識。