怎么实现所有线程在等待某个事件的发生才会去执行

方案一:读写锁

刚开始主线程先获取写锁,然后所有子线程获取读锁,然后等事件发生时主线程释放写锁;

方案二:CountDownLatch

CountDownLatch初始值设为1,所有子线程调用await方法等待,等事件发生时调用countDown方法计数减为0;

方案三:Semaphore

Semaphore初始值设为N,刚开始主线程先调用acquire(N)申请N个信号量,其它线程调用acquire()阻塞等待,等事件发生时同时主线程释放N个信号量;

package com.qimh.concurrent;

import java.util.concurrent.CountDownLatch;

public class CountDownLatchDemo {
	
	
	
	
	 /** 
     * 模拟爸爸去饭店 
     */  
    public static void fatherToRes()  
    {  
        System.out.println("爸爸步行去饭店需要3小时。");  
    }  
  
    /** 
     * 模拟我去饭店 
     */  
    public static void motherToRes()  
    {  
        System.out.println("妈妈挤公交去饭店需要2小时。");  
    }  
  
    /** 
     * 模拟妈妈去饭店 
     */  
    public static void meToRes()  
    {  
        System.out.println("我乘地铁去饭店需要1小时。");  
    }  
  
    /** 
     * 模拟一家人到齐了 
     */  
    public static void togetherToEat()  
    {  
        System.out.println("一家人到齐了,开始吃饭");  
    }  

	
	private static CountDownLatch latch = new CountDownLatch(3);  
	  
    public static void main(String[] args) throws InterruptedException  
    {  
  
        new Thread()  
        {  
            public void run()  
            {  
                fatherToRes();  
                latch.countDown();  
            };  
        }.start();  
        new Thread()  
        {  
            public void run()  
            {  
                motherToRes();  
                latch.countDown();  
            };  
        }.start();  
        new Thread()  
        {  
            public void run()  
            {  
                meToRes();  
                latch.countDown();  
            };  
        }.start();  
  
        latch.await();  
        togetherToEat();  
    }  
}

 


版权声明:本文为z15732621582原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。