【完整代码】使用Semaphore实现限流代码示例

柔光的暖阳◎ 2023-10-06 08:22 32阅读 0赞

import java.util.concurrent.Semaphore;
    
    /**
        Semaphore信号量 基于AQS（内部维护了一个队列）可以用于限流 最多允许多少线程同时运行
        可以有很多个线程  但同时允许运行的线程有限制2个 new Semaphore(2)
    */
    public class T11_TestSemaphore {
        
        public static void main(String[] args) {
        
            //允许一个线程同时执行
            // Semaphore s = new Semaphore(1);
            // 允许两个纤程同时执行
            Semaphore s = new Semaphore(2);
            //2 同时允许两个线程运行  true 公平与否 默认非公平
            // Semaphore s = new Semaphore(2, true);
    
            new Thread(()->{
        
                try {
        
                    s.acquire();//获得许可 一共就2个许可
    
                    System.out.println("T1 running...");
                    Thread.sleep(200);
                    System.out.println("T1 running...");
    
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                } finally {
        
                    s.release();
                }
            }).start();
    
            new Thread(()->{
        
                try {
        
                    s.acquire();
    
                    System.out.println("T2 running...");
                    Thread.sleep(200);
                    System.out.println("T2 running...");
    
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                } finally {
        
                    s.release();
                }
            }).start();
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200508172148222.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk=,size_16,color_FFFFFF,t_70