信号量(Semaphore),有时被称为信号灯,是在多线程环境下使用的一种设施, 它负责协调各个线程, 以保证它们可以正确、合理的使用公共资源。多线程
Semaphore分为单值和多值两种,前者只能被一个线程得到,后者能够被若干个线程得到。并发
Semaphore当前在多线程环境下被扩放使用,操做系统的信号量是个很重要的概念,在进程控制方面都有应用。Java并发库Semaphore 能够很轻松完成信号量控制,Semaphore能够控制某个资源可被同时访问的个数,经过 acquire() 获取一个许可,若是没有就等待,而 release() 释放一个许可。好比在Windows下能够设置共享文件的最大客户端访问个数。dom
单个信号量的Semaphore对象能够实现互斥锁的功能,而且能够是由一个线程得到了“锁”,再由另外一个线程释放“锁”,这可应用于死锁恢复的一些场合。ide
如今有一个三个信号灯,启动10个线程分别获取信号灯,当信号灯被占用时,其余线程只能等待,当信号灯被释放则等待线程获取信号灯。ui
1 public class SemaphoreTest { 2 public static void main(String[] args) { 3 ExecutorService pool = Executors.newCachedThreadPool(); 4 final Semaphore semaphore = new Semaphore(3,true); 5 6 for (int i = 0; i < 10; i++) { 7 Runnable runnable = new Runnable() { 8 @Override 9 public void run() { 10 try { 11 semaphore.acquire();//获取信号灯许可 12 } catch (InterruptedException e) { 13 // TODO Auto-generated catch block 14 e.printStackTrace(); 15 } 16 System.out.println("Thread "+Thread.currentThread().getName()+" 进入" +"当前系统的并发数是:"+(3-semaphore.availablePermits())); 17 try { 18 Thread.sleep(new Random().nextInt(1000)); 19 } catch (InterruptedException e) { 20 // TODO Auto-generated catch block 21 e.printStackTrace(); 22 } 23 System.out.println("Thread "+Thread.currentThread().getName()+" 即将离开"); 24 semaphore.release();//释放信号灯 25 System.out.println("Thread "+Thread.currentThread().getName()+" 已经离开,当前系统的并发数是:"+(3-semaphore.availablePermits())); 26 } 27 }; 28 pool.execute(runnable); 29 30 } 31 } 32 }
另外须要注意的一点是,信号灯能够由一个线程使用,而后由另外一个线程来进行释放,而锁只能由同一个线程启动和释放,否则就好发生死锁,这一点须要格外注意。spa