并发控制(7)信号量

雨点打透心脏的1/2处 2022-07-16 23:15 142阅读 0赞

### 并发控制(7)信号量 ###

*  Semaphore实现的功能就类似厕所有5个坑，假如有10个人要上厕所，那么同时只能有多少个人去上厕所呢？同时只能有5个人能够占用，当5个人中 的任何一个人让开后，其中等待的另外5个人中又有一个人可以占用了。另外等待的5个人中可以是随机获得优先机会，也可以是按照先来后到的顺序获得机会，这取决于构造Semaphore对象时传入的参数选项。
 *  典型的应用场景，可以是限制JAVA程序的访问数量，比如我相对制定的程序做个压力测试，我想限制线访问的流量啥的，可以用这个.

--------------------

#### 有如下代码，最多只能有5个线程同时访问 ####

import java.util.concurrent.ExecutorService;  
    import java.util.concurrent.Executors;  
    import java.util.concurrent.Semaphore;  
    
    public class UseSemaphore {   
    
        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));  
                            // 访问完后，释放 
                            semp.release();  
                        } catch (InterruptedException e) {  
                        }  
                    }  
                };  
                exec.execute(run);  
            } 
    
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            //System.out.println(semp.getQueueLength());
    
    
    
            // 退出线程池 
            exec.shutdown();  
        }  
    
    }