?Java的信號量實際上是一個功能完畢的計數器，對控制一定資源的消費與回收有著很重要的意義，信號量常常用于多線程的代碼中，并能監控有多少數目的線程等待獲取資源，并且通過信號量可以得知可用資源的數目等等，這里總是在強調“數目”二字，但不能指出來有哪些在等待，哪些資源可用。

????????因此，本人認為，這個信號量類如果能返回數目，還能知道哪些對象在等待，哪些資源可使用，就非常完美了，僅僅拿到這些概括性的數字，對精確控制意義不是很大。目前還沒想到更好的用法。

????????下面是一個簡單例子：

import?java.util.concurrent.ExecutorService;?? import?java.util.concurrent.Executors;?? import?java.util.concurrent.Semaphore;??/**?*?Java線程：線程池-信號量?*/?? public?class?Test?{??public?static?void?main(String[]?args){??MyPool?myPool?=?new?MyPool(20);??//創建線程池??ExecutorService?threadPool?=?Executors.newFixedThreadPool(2);??MyThread?t1?=?new?MyThread("任務A",?myPool,?3);??MyThread?t2?=?new?MyThread("任務B",?myPool,?12);??MyThread?t3?=?new?MyThread("任務C",?myPool,?7);??//在線程池中執行任務??threadPool.execute(t1);??threadPool.execute(t2);??threadPool.execute(t3);??//關閉池??threadPool.shutdown();??}?? }?? class?MyPool?{??private?Semaphore?sp;????//池相關的信號量??/**?*?池的大小，這個大小會傳遞給信號量?*?@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;????????????//線程的名稱??private?MyPool?pool;?????????????????//自定義池??private?int?x;??????????????????????//申請信號量的大小??MyThread(String?threadname,?MyPool?pool,?int?x)?{??this.threadname?=?threadname;??this.pool?=?pool;??this.x?=?x;??}??public?void?run()?{??try?{??//從此信號量獲取給定數目的許可??pool.getSp().acquire(x);??//todo：也許這里可以做更復雜的業務??System.out.println(threadname?+?"成功獲取了"?+?x?+"個許可！");??}?catch?(InterruptedException?e)?{??e.printStackTrace();??}?finally?{??//釋放給定數目的許可，將其返回到信號量。??pool.getSp().release(x);??System.out.println(threadname?+?"釋放了"?+?x?+"個許可！");??}??}?? }

??
????????執行結果：

任務A成功獲取了3個許可！?? 任務B成功獲取了12個許可！?? 任務B釋放了12個許可！?? 任務A釋放了3個許可！?? 任務C成功獲取了7個許可！?? 任務C釋放了7個許可！??

????????從結果可以看出，信號量僅僅是對池資源進行監控，但不保證線程的安全，因此，在使用時候，應該自己控制線程的安全訪問池資源。
?

總結

以上是生活随笔為你收集整理的Java线程详解(14)-信号量的全部內容，希望文章能夠幫你解決所遇到的問題。

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