信号量,倒计时锁,CyclicBarrier

柔光的暖阳◎ 2023-10-07 12:31 10阅读 0赞

![在这里插入图片描述][20200413095156460.png]

public class SemaphoreTest{
        	
    	public static void main(String[] args) {
        
    		ExecutorService ex=Executors.newCachedThreadPool();	
    		//创建信号量
    		Semaphore semaphore=new Semaphore(5);//每次我有五个位置,准许一次性通过5个人,后续的人都等待
    		for (int i = 1; i < 20; i++) {
        
    		  //final	int  index=i;
    			ex.execute(new Runnable() {
        
    				@Override
    				public void run() {
        
    				//栈位置	  
    			try {
        
    //				semaphore.acquire();//占用该位置 其他人等待吧	
    				//尝试获得信号量的这么一个操作
    				//每次只允许五个人操作，其他他人全部重新登录
    				if (semaphore.tryAcquire()) {
        
    				//也是尝试获得信号量,但是会给5S的等待时间,5s后静止登录
    //				if (semaphore.tryAcquire(5,TimeUnit.SECONDS)) {
        
    					
    					//对应的操作  TODO	
    					play();
    					semaphore.release();		
    				}else {
        
    					System.out.println("服务器已满，请稍后的尝试登录");
    				}			
    			} catch (Exception e) {
        
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}	
    				}
    			});
    		}
    		ex.shutdown();
    	}
    	
    	/**
    	 * 玩游戏
    	 */
    	public static void  play() {
        
    		try {
        
    		System.out.println(new Date()+":"+Thread.currentThread().getName()+"获得进入紫禁之巅的资格");	
    			Thread.sleep(2000L);//玩的时间		
    			//玩了二秒 就退出
    			System.out.println(new Date()+":"+Thread.currentThread().getName()+"退出游戏");
    			Thread.sleep(500L);
    		} catch (Exception e) {
        
     			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    }

服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    Mon Apr 13 09:46:40 CST 2020:pool-1-thread-5获得进入紫禁之巅的资格
    Mon Apr 13 09:46:40 CST 2020:pool-1-thread-1获得进入紫禁之巅的资格
    Mon Apr 13 09:46:40 CST 2020:pool-1-thread-4获得进入紫禁之巅的资格
    Mon Apr 13 09:46:40 CST 2020:pool-1-thread-3获得进入紫禁之巅的资格
    Mon Apr 13 09:46:40 CST 2020:pool-1-thread-2获得进入紫禁之巅的资格
    Mon Apr 13 09:46:42 CST 2020:pool-1-thread-3退出游戏
    Mon Apr 13 09:46:42 CST 2020:pool-1-thread-4退出游戏
    Mon Apr 13 09:46:42 CST 2020:pool-1-thread-5退出游戏
    Mon Apr 13 09:46:42 CST 2020:pool-1-thread-1退出游戏
    Mon Apr 13 09:46:42 CST 2020:pool-1-thread-2退出游戏

也是尝试获得信号量,但是会给5S的等待时间,5s后静止登录

if (semaphore.tryAcquire(5,TimeUnit.SECONDS)) {
        			
    					//对应的操作  TODO	
    					play();
    					semaphore.release();		
    				}else {
        
    					System.out.println("服务器已满，请稍后的尝试登录");
    				}

Mon Apr 13 09:48:43 CST 2020:pool-1-thread-2获得进入紫禁之巅的资格
    Mon Apr 13 09:48:43 CST 2020:pool-1-thread-4获得进入紫禁之巅的资格
    Mon Apr 13 09:48:43 CST 2020:pool-1-thread-1获得进入紫禁之巅的资格
    Mon Apr 13 09:48:43 CST 2020:pool-1-thread-5获得进入紫禁之巅的资格
    Mon Apr 13 09:48:43 CST 2020:pool-1-thread-3获得进入紫禁之巅的资格
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-2退出游戏
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-1退出游戏
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-4退出游戏
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-5退出游戏
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-3退出游戏
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-7获得进入紫禁之巅的资格
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-6获得进入紫禁之巅的资格
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-8获得进入紫禁之巅的资格
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-9获得进入紫禁之巅的资格
    Mon Apr 13 09:48:45 CST 2020:pool-1-thread-10获得进入紫禁之巅的资格
    Mon Apr 13 09:48:47 CST 2020:pool-1-thread-6退出游戏
    Mon Apr 13 09:48:47 CST 2020:pool-1-thread-7退出游戏
    Mon Apr 13 09:48:47 CST 2020:pool-1-thread-9退出游戏
    Mon Apr 13 09:48:47 CST 2020:pool-1-thread-8退出游戏
    Mon Apr 13 09:48:47 CST 2020:pool-1-thread-10退出游戏
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录
    服务器已满，请稍后的尝试登录

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

public class CountDown {
        
    	private static int count=0;
    	public static void main(String[] args){
        
    		ExecutorService ex=Executors.newFixedThreadPool(100);
    		CountDownLatch ch=new CountDownLatch(10000);//要跟线程数量保持一致的
    		
    		//累加的操作
    		for (int i = 0; i <=10000; i++) {
        
    			int index=i;
    			ex.execute(new Runnable() {
        
    				
    				@Override
    				public void run() {
        		
    					try {
        
    						synchronized (CountDown.class) {
        
    							count =count+index;			
    							}				
    					} catch (Exception e) {
        
    						e.printStackTrace();
    					}finally {
        						
    						ch.countDown();//随着累加 我要减一个 保持一致   减减操作
    					}
    				}
    			}); 
    		}		
    		//这里的睡眠！有问题！   如果你有上w的数据  你不知道要睡多久  所以考虑用倒计时锁
           //Thread.sleep(1000L);
    		try {
        
    			ch.await();
    		} catch (InterruptedException e) {
        
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}//
    		System.out.println("值为"+count);
    	}
    
    }

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

public class CyclicBarrierSample {
        
    	
    	static CyclicBarrier barrier = new CyclicBarrier(5);      //5个值，等5个线程都凑齐后开始同时运行
    	
    	
        public static void main(String[] args) {
        
        	ExecutorService ex = Executors.newCachedThreadPool();
        	
        	
        	//5个线程
        	for(int i = 1; i<= 5; i++) {
        
        		try {
        
    				Thread.sleep(1000L);    //等待1秒的时间，总共等待的时间是5秒
    			} catch (InterruptedException e) {
        
    				e.printStackTrace();
    			}
        		ex.execute(new Runnable() {
        
    				
    				@Override
    				public void run() {
        
    					//TODO
    					go();
    				}
    			});
        	}
    	}
        
        /**
         * 跑的方法
         */
        public static void go() {
        
        	System.out.println(Thread.currentThread().getName() + "准备就绪");
        	
        	try {
         
    			barrier.await();    //阻塞
    			System.out.println(Thread.currentThread().getName() + "运行了");
    		} catch (InterruptedException | BrokenBarrierException e) {
        
    			e.printStackTrace();
    		}
        	
        }
    }

pool-1-thread-1准备就绪
    pool-1-thread-2准备就绪
    pool-1-thread-3准备就绪
    pool-1-thread-4准备就绪
    pool-1-thread-5准备就绪
    pool-1-thread-5运行了
    pool-1-thread-1运行了
    pool-1-thread-4运行了
    pool-1-thread-3运行了
    pool-1-thread-2运行了

[20200413095156460.png]: https://img-blog.csdnimg.cn/20200413095156460.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NxTDUyMGxU_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200413095049785.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NxTDUyMGxU,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NxTDUyMGxU_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200413095454594.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NxTDUyMGxU,size_16,color_FFFFFF,t_70