标签:style class blog code java color
1.概念
Semaphore可以维护当前访问自身的线程个数,并提供了同步机制。使用Semaphore可以控制同时访问资源的线程个数,例如,实现一个文件允许的并发访问数
2.案例
package org.lkl.thead.foo; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * * Function : 信号灯 * @author : Liaokailin * CreateDate : 2014-6-19 * version : 1.0 */ public class SemaphoreFoo { public static void main(String[] args) { ExecutorService threadPool = Executors.newCachedThreadPool() ; final Semaphore sp = new Semaphore(3) ; //3个信号等 for(int i= 1 ;i<=10 ;i++){ Runnable runnable = new Runnable() { @Override public void run() { //获取一个信号灯 try { sp.acquire() ; } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("线程:"+Thread.currentThread().getName()+ " 获得信号灯 开始工作,当前并发的线程有:"+(3-sp.availablePermits())); try { Thread.sleep((long)(Math.random()*10000)) ;//线程休眠 (模拟线程的业务执行) } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("线程:"+Thread.currentThread().getName()+"即将释放信号灯."); sp.release() ; //释放信号灯 此时其他线程就可以抢占释放的信号灯 //下面代码有时候执行不准确,因为其没有和上面的代码合成原子单元 System.out.println("线程" + Thread.currentThread().getName() + "已离开,当前已有" + (3-sp.availablePermits()) + "个并发"); } }; threadPool.execute(runnable) ; //线程启动. } } }
多线程11-Semaphore信号灯,布布扣,bubuko.com
标签:style class blog code java color
原文地址:http://www.cnblogs.com/liaokailin/p/3796822.html