多线程11-Semaphore信号灯

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

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个信号等

        for(int i=  ;i<= ;i++){

            Runnable runnable = new Runnable() {

                @Override

                public void run() {

                        //获取一个信号灯

                        try {

                            sp.acquire() ;

                        } catch (InterruptedException e) {

                            e.printStackTrace();

                        }

                        System.out.println("线程:"+Thread.currentThread().getName()+

                                " 获得信号灯 开始工作,当前并发的线程有:"+(-sp.availablePermits()));

                        try {

                            Thread.sleep((long)(Math.random()*)) ;//线程休眠 （模拟线程的业务执行）

                        } catch (InterruptedException e) {

                            e.printStackTrace();

                        } 

                        System.out.println("线程:"+Thread.currentThread().getName()+"即将释放信号灯.");

                            sp.release() ; //释放信号灯 此时其他线程就可以抢占释放的信号灯

                            //下面代码有时候执行不准确，因为其没有和上面的代码合成原子单元

                            System.out.println("线程" + Thread.currentThread().getName() +

                                    "已离开，当前已有" + (-sp.availablePermits()) + "个并发");

                }

            };

            threadPool.execute(runnable) ; //线程启动.

        }

    }

}