日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

CountDownLatch应用实战

發布時間:2023/12/4 编程问答 32 豆豆
生活随笔 收集整理的這篇文章主要介紹了 CountDownLatch应用实战 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

2019獨角獸企業重金招聘Python工程師標準>>>

1. CountDownLatch簡介

? ? ? ?一個同步輔助類,在完成一組正在其他線程中執行的操作之前,它允許一個或多個線程一直等待。其本質就是一個共享鎖。

? ? ? ?他最主要的作用是用來同步java的線程。

主要有以下三個方法:

主要方法:

?public?CountDownLatch(int?count);public?void?countDown();public?void?await();

構造方法參數指定了計數的次數

countDown方法,當前線程調用此方法,則計數減一

await方法,調用此方法會一直阻塞當前線程,直到計時器的值為0

?2. 實戰應用的例子

? ? ? ? ?一個模擬運動員比賽的例子,首先要等所有的運動員全部給準備好,然后發起“起跑指令”所有的運動員開始起跑,等所有的運動員跑完才結束本次筆試。

代碼如下:

運動員線程代碼:

package?it_cast.day01; import?java.util.concurrent.CountDownLatch; public?class?Player?implements?Runnable?{private?int?id;private?CountDownLatch?begin;private?CountDownLatch?end;public?Player(int?id,?CountDownLatch?begin,?CountDownLatch?end)?{this.id=id;this.begin=begin;this.end=end;}@Overridepublic?void?run()?{//?TODO?Auto-generated?method?stubtry?{System.out.println("Play"?+?id?+?"ready");begin.await();//?所有的運動員在這準備者,當一聲令下就開始跑Thread.sleep((long)?(Math.random()?*?100));//?隨機分配時間,即運動員完成時間System.out.println("Play"?+?id?+?"?arrived.");}?catch?(InterruptedException?e)?{//?TODO?Auto-generated?catch?blocke.printStackTrace();}?finally?{end.countDown();//?每個運動員跑完,使end狀態減1,最終減至0}????????} }

主代碼:

package?it_cast.day01; import?java.util.concurrent.CountDownLatch; import?java.util.concurrent.ExecutorService; import?java.util.concurrent.Executors; public?class?CountDownLatchDemo?{private?static?final?int?PLAYER_AMOUNT?=?5;public?static?void?main(String[]?args)?throws?InterruptedException?{//?TODO?Auto-generated?method?stub//對于每位運動員,CountDownLatch減1后即結束比賽CountDownLatch?begin?=?new?CountDownLatch(1);//對于整個比賽,所有運動員結束后才算結束CountDownLatch?end?=?new?CountDownLatch(PLAYER_AMOUNT);Player?[]?plays=new?Player[PLAYER_AMOUNT];//初始化5個運動員for?(int?i?=?0;?i?<?plays.length;?i++)?{plays[i]=new?Player(i,?begin,?end);}//設置特定的線程池,大小為5ExecutorService?exe?=?Executors.newFixedThreadPool(PLAYER_AMOUNT);for(Player?p:plays)exe.execute(p);?Thread.sleep(1000);System.out.println("Race?begins!");begin.countDown();end.await();;?//等待end狀態變為0,即為所有人都跑完了,即為比賽結束System.out.println("Race?ends!");exe.shutdown();?????} }

運行結果如下:

?

轉載于:https://my.oschina.net/u/1540325/blog/603298

總結

以上是生活随笔為你收集整理的CountDownLatch应用实战的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。