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

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > java >内容正文

java

Java多线程:Semaphore

發布時間:2025/3/21 java 17 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Java多线程:Semaphore 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

自從5.0開始,jdk在java.util.concurrent包里提供了Semaphore 的官方實現。
Java 5.0里新加了4個協調線程間進程的同步裝置,它們分別是: Semaphore, CountDownLatch, CyclicBarrier和Exchanger.


Semaphore為并發包中提供用于控制某資源同時可以被幾個線程訪問的類。


Semaphore當前在多線程環境下被擴放使用,操作系統的信號量是個很重要的概念,在進程控制方面都有應用。Java 并發庫 的Semaphore 可以很輕松完成信號量控制,Semaphore可以控制某個資源可被同時訪問的個數,通過 acquire() 獲取一個許可,如果沒有就等待,而 release() 釋放一個許可。


Semaphore維護了當前訪問的個數,提供同步機制,控制同時訪問的個數。在數據結構中鏈表可以保存“無限”的節點,用Semaphore可以實現有限大小的鏈表。另外重入鎖 ReentrantLock 也可以實現該功能,但實現上要復雜些。


Constructor and Description
Semaphore(int permits)
Creates a Semaphore with the given number of permits and nonfair fairness setting.
permits 初始許可數,最大訪問線程數
Semaphore(int permits, boolean fair)
Creates a Semaphore with the given number of permits and the given fairness setting.
permits 初始許可數,最大訪問線程數
fair 當設置為false時,線程獲取許可的順序是無序的,也就是說新線程可能會比等待的老線程會先獲得許可;當設置為true時,信號量保證它們調用的順序(即先進先出;FIFO)


主要方法:
void acquire() 從信號量獲取一個許可,如果無可用許可前 將一直阻塞等待,
void acquire(int permits) 獲取指定數目的許可,如果無可用許可前 也將會一直阻塞等待
boolean tryAcquire() 從信號量嘗試獲取一個許可,如果無可用許可,直接返回false,不會阻塞
boolean tryAcquire(int permits) 嘗試獲取指定數目的許可,如果無可用許可直接返回false,
boolean tryAcquire(int permits, long timeout, TimeUnit unit) 在指定的時間內嘗試從信號量中獲取許可,如果在指定的時間內獲取成功,返回true,否則返回false
void release() 釋放一個許可,別忘了在finally中使用,注意:多次調用該方法,會使信號量的許可數增加,達到動態擴展的效果,如:初始permits 為1, 調用了兩次release,最大許可會改變為2
int availablePermits() 獲取當前信號量可用的許可


import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit;public class SemaphoreTest {public static void main(String[] args) {// 線程池ExecutorService exec = Executors.newCachedThreadPool();// 只能5個線程同時訪問final Semaphore semp = new Semaphore(5);// 模擬20個客戶端訪問for (int index = 0; index < 20; index++) {final int NO = index;Runnable run = new Runnable() {public void run() {try {// 獲取許可semp.acquire();System.out.println("Accessing: " + NO);// Thread.sleep((long) (Math.random() * 10000));TimeUnit.SECONDS.sleep((long) (Math.random()*1000));// 訪問完后,釋放semp.release();System.out.println("----------availablePermits-------" + semp.availablePermits());} catch (InterruptedException e) {e.printStackTrace();}}};exec.execute(run);}// 退出線程池exec.shutdown();}}

總結

以上是生活随笔為你收集整理的Java多线程:Semaphore的全部內容,希望文章能夠幫你解決所遇到的問題。

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