Java中怎么模擬高并發(fā),相信很多沒有經(jīng)驗(yàn)的人對此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個問題。
創(chuàng)新互聯(lián)-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價比播州網(wǎng)站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫,直接使用。一站式播州網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們,業(yè)務(wù)覆蓋播州地區(qū)。費(fèi)用合理售后完善,10余年實(shí)體公司更值得信賴。
1、Semaphore
JDK 1.5之后會提供這個類
Semaphore是一種基于計(jì)數(shù)的信號量。它可以設(shè)定一個閾值,基于此,多個線程競爭獲取許可信號,做完自己的申請后歸還,超過閾值后,線程申請?jiān)S可信號將會被阻塞。Semaphore可以用來構(gòu)建一些對象池,資源池之類的,比如數(shù)據(jù)庫連接池,我們也可以創(chuàng)建計(jì)數(shù)為1的Semaphore,將其作為一種類似互斥鎖的機(jī)制,這也叫二元信號量,表示兩種互斥狀態(tài)。
2、CountDownLatch
JDK 1.5之后會提供這個類,
CountDownLatch這個類能夠使一個線程等待其他線程完成各自的工作后再執(zhí)行。例如,應(yīng)用程序的主線程希望在負(fù)責(zé)啟動框架服務(wù)的線程已經(jīng)啟動所有的框架服務(wù)之后再執(zhí)行。
CountDownLatch是通過一個計(jì)數(shù)器來實(shí)現(xiàn)的,計(jì)數(shù)器的初始值為線程的數(shù)量。每當(dāng)一個線程完成了自己的任務(wù)后,計(jì)數(shù)器的值就會減1。當(dāng)計(jì)數(shù)器值到達(dá)0時,它表示所有的線程已經(jīng)完成了任務(wù),然后在閉鎖上等待的線程就可以恢復(fù)執(zhí)行任務(wù)。
如下圖:
以上兩個類可以搭配使用,達(dá)到模擬高并發(fā)的效果,以下使用代碼的形式進(jìn)行舉例:
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 { // 請求總數(shù) public static int clientTotal = 5000; // 同時并發(fā)執(zhí)行的線程數(shù) public static int threadTotal = 200; public static int count = 0; public static void main(String[] args) throws Exception { ExecutorService executorService = Executors.newCachedThreadPool(); //信號量,此處用于控制并發(fā)的線程數(shù) final Semaphore semaphore = new Semaphore(threadTotal); //閉鎖,可實(shí)現(xiàn)計(jì)數(shù)器遞減 final CountDownLatch countDownLatch = new CountDownLatch(clientTotal); for (int i = 0; i < clientTotal ; i++) { executorService.execute(() -> { try { //執(zhí)行此方法用于獲取執(zhí)行許可,當(dāng)總計(jì)未釋放的許可數(shù)不超過200時, //允許通行,否則線程阻塞等待,直到獲取到許可。 semaphore.acquire(); add(); //釋放許可 semaphore.release(); } catch (Exception e) { //log.error("exception", e); e.printStackTrace(); } //閉鎖減一 countDownLatch.countDown(); }); } countDownLatch.await();//線程阻塞,直到閉鎖值為0時,阻塞才釋放,繼續(xù)往下執(zhí)行 executorService.shutdown(); log.info("count:{}", count); } private static void add() { count++; } }
如上方法模擬5000次請求,同時最大200個并發(fā)操作,觀察最后的結(jié)果,發(fā)現(xiàn)每次的結(jié)果都有差別,和預(yù)期不符,得出結(jié)果部分如下:
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
最后結(jié)論:add 方法 非線程安全
那如何保證add方法 線程安全,將add方法進(jìn)行如下修改即可:
private static void add() { count.incrementAndGet(); }
執(zhí)行結(jié)果如下:
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
看完上述內(nèi)容,你們掌握J(rèn)ava中怎么模擬高并發(fā)的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀!
網(wǎng)頁名稱:Java中怎么模擬高并發(fā)
本文URL:http://bm7419.com/article18/pcgsgp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供外貿(mào)建站、靜態(tài)網(wǎng)站、微信小程序、域名注冊、Google、標(biāo)簽優(yōu)化
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)