Java使用代碼模擬高並發操作的示例

在java中，使用了synchronized關鍵字和Lock鎖實現了資源的並發訪問控制，在同一時間只允許唯一了線程進入臨界區訪問資源(讀鎖除外)，這樣子控制的主要目的是為了解決多個線程並發同一資源造成的數據不一致的問題。在另外一種場景下，一個資源有多個副本可供同時使用，比如打印機房有多個打印機、廁所有多個坑可供同時使用，這種情況下，Java提供了另外的並發訪問控制--資源的多副本的並發訪問控制，今天使用的Semaphore即是其中的一種。

Java通過代碼模擬高並發可以以最快的方式發現我們系統中潛在的線程安全性問題，此處使用Semaphore（信號量）和CountDownLatch（閉鎖）搭配ExecutorService（線程池）來進行模擬，主要介紹如下：

1、Semaphore

JDK 1.5之後會提供這個類

Semaphore是一種基於計數的信號量。它可以設定一個閾值，基於此，多個線程競爭獲取許可信號，做完自己的申請後歸還，超過閾值後，線程申請許可信號將會被阻塞。 Semaphore可以用來構建一些對像池，資源池之類的，比如數據庫連接池，我們也可以創建計數為1的Semaphore，將其作為一種類似互斥鎖的機制，這也叫二元信號量，表示兩種互斥狀態。

2、CountDownLatch

JDK 1.5之後會提供這個類，

CountDownLatch這個類能夠使一個線程等待其他線程完成各自的工作後再執行。例如，應用程序的主線程希望在負責啟動框架服務的線程已經啟動所有的框架服務之後再執行。

CountDownLatch是通過一個計數器來實現的，計數器的初始值為線程的數量。每當一個線程完成了自己的任務後，計數器的值就會減1。當計數器值到達0時，它表示所有的線程已經完成了任務，然後在閉鎖上等待的線程就可以恢復執行任務。

如下圖：

以上兩個類可以搭配使用，達到模擬高並發的效果，以下使用代碼的形式進行舉例：

 package modules;import java.util.concurrent.CountDownLatch;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Semaphore;public class CountExample { // 請求總數public static int clientTotal = 5000; // 同時並發執行的線程數public static int threadTotal = 200; public static int count = 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 { //執行此方法用於獲取執行許可，當總計未釋放的許可數不超過200時， //允許通行，否則線程阻塞等待，直到獲取到許可。 semaphore.acquire(); add(); //釋放許可semaphore.release(); } catch (Exception e) { //log.error("exception", e); e.printStackTrace(); } //閉鎖減一countDownLatch.countDown(); }); } countDownLatch.await();//線程阻塞，直到閉鎖值為0時，阻塞才釋放，繼續往下執行executorService.shutdown(); log.info("count:{}", count); } private static void add() { count++; }}

如上方法模擬5000次請求，同時最大200個並發操作，觀察最後的結果，發現每次的結果都有差別，和預期不符，得出結果部分如下：

22:18:26.449 [main] INFO modules.CountExample - count:4997
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:4995
22:18:26.449 [main] INFO modules.CountExample - count:4998

最後結論：add 方法非線程安全

那如何保證add方法線程安全，將add方法進行如下修改即可：

 private static void add() { count.incrementAndGet();}

執行結果如下：

22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000

最後結論：修改後的add 方法線程安全

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。