Java线程详解(14)-信号量
生活随笔
收集整理的這篇文章主要介紹了
Java线程详解(14)-信号量
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
?Java的信號(hào)量實(shí)際上是一個(gè)功能完畢的計(jì)數(shù)器,對(duì)控制一定資源的消費(fèi)與回收有著很重要的意義,信號(hào)量常常用于多線程的代碼中,并能監(jiān)控有多少數(shù)目的線程等待獲取資源,并且通過(guò)信號(hào)量可以得知可用資源的數(shù)目等等,這里總是在強(qiáng)調(diào)“數(shù)目”二字,但不能指出來(lái)有哪些在等待,哪些資源可用。
????????因此,本人認(rèn)為,這個(gè)信號(hào)量類(lèi)如果能返回?cái)?shù)目,還能知道哪些對(duì)象在等待,哪些資源可使用,就非常完美了,僅僅拿到這些概括性的數(shù)字,對(duì)精確控制意義不是很大。目前還沒(méi)想到更好的用法。
????????下面是一個(gè)簡(jiǎn)單例子:
import?java.util.concurrent.ExecutorService;?? import?java.util.concurrent.Executors;?? import?java.util.concurrent.Semaphore;??/**?*?Java線程:線程池-信號(hào)量?*/?? public?class?Test?{??public?static?void?main(String[]?args){??MyPool?myPool?=?new?MyPool(20);??//創(chuàng)建線程池??ExecutorService?threadPool?=?Executors.newFixedThreadPool(2);??MyThread?t1?=?new?MyThread("任務(wù)A",?myPool,?3);??MyThread?t2?=?new?MyThread("任務(wù)B",?myPool,?12);??MyThread?t3?=?new?MyThread("任務(wù)C",?myPool,?7);??//在線程池中執(zhí)行任務(wù)??threadPool.execute(t1);??threadPool.execute(t2);??threadPool.execute(t3);??//關(guān)閉池??threadPool.shutdown();??}?? }?? class?MyPool?{??private?Semaphore?sp;????//池相關(guān)的信號(hào)量??/**?*?池的大小,這個(gè)大小會(huì)傳遞給信號(hào)量?*?@param?size?池的大小?*/??MyPool(int?size)?{??this.sp?=new?Semaphore(size);??}??public?Semaphore?getSp()?{??return?sp;??}??public?void?setSp(Semaphore?sp)?{??this.sp?=?sp;??}?? }?? class?MyThread?extends?Thread?{??private?String?threadname;????????????//線程的名稱(chēng)??private?MyPool?pool;?????????????????//自定義池??private?int?x;??????????????????????//申請(qǐng)信號(hào)量的大小??MyThread(String?threadname,?MyPool?pool,?int?x)?{??this.threadname?=?threadname;??this.pool?=?pool;??this.x?=?x;??}??public?void?run()?{??try?{??//從此信號(hào)量獲取給定數(shù)目的許可??pool.getSp().acquire(x);??//todo:也許這里可以做更復(fù)雜的業(yè)務(wù)??System.out.println(threadname?+?"成功獲取了"?+?x?+"個(gè)許可!");??}?catch?(InterruptedException?e)?{??e.printStackTrace();??}?finally?{??//釋放給定數(shù)目的許可,將其返回到信號(hào)量。??pool.getSp().release(x);??System.out.println(threadname?+?"釋放了"?+?x?+"個(gè)許可!");??}??}?? }??
????????執(zhí)行結(jié)果:
????????從結(jié)果可以看出,信號(hào)量?jī)H僅是對(duì)池資源進(jìn)行監(jiān)控,但不保證線程的安全,因此,在使用時(shí)候,應(yīng)該自己控制線程的安全訪問(wèn)池資源。
?
總結(jié)
以上是生活随笔為你收集整理的Java线程详解(14)-信号量的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: Java线程详解(13)-锁
- 下一篇: Java线程详解(15)-阻塞队列和阻塞