计数信号量 Semaphore 的使用

Semaphore类是一个计数信号量，必须由获取它的线程释放。通常用于控制同时访问特定资源的线程数目。

 

可以将Semaphore理解成一个停车场，里面有指定数量的停车位。acquire就是申请占用一个停车位，release就是释放一个停车位。

 

package com.seasy.test;

import java.util.Random;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

public class SemaphoreTest {
	private static Semaphore semaphore;
	private static Random rnd = new Random();
	
	public static void main(String[] args) {
		semaphore = new Semaphore(3); //初始化许可证数量
		System.out.println(semaphore.availablePermits()); //当前可用的许可证数量
		//System.out.println(semaphore.drainPermits()); //获得并返回剩余所有可用的许可证
		System.out.println(semaphore.getQueueLength()); //获取当前Semaphore对象上正在等待许可证的线程数量
		System.out.println(semaphore.hasQueuedThreads()); //判断当前Semaphore对象上是否存在正在等待许可证的线程
		System.out.println(semaphore.isFair()); //是否公平模式FIFO
		
		for(int i=0; i<10; i++){
			Thread thread = new Thread(new Runnable() {
				@Override
				public void run() {
					try{
						//boolean b = semaphore.acquire(); //阻塞式获取一个许可，线程可中断
						//semaphore.acquireUninterruptibly(); //阻塞式获取一个许可，线程不可中断
						boolean b = semaphore.tryAcquire(); //非阻塞式获取一个许可
						
						if(b){
							int value = rnd.nextInt(2000);
							if(value < 100){
								value = 100;
							}
							System.out.println(Thread.currentThread().getName() + ": " + value);
							
							TimeUnit.MILLISECONDS.sleep(value);
							
							semaphore.release(); //释放一个许可
							System.out.println(Thread.currentThread().getName() + " ok");
						}
						
					}catch(Exception ex){
						ex.printStackTrace();
					}
				}
			});
			
			thread.start();
		}
		
		System.out.println("ok");
	}	
}