Java CountDownLatch 使用

布满荆棘的人生 2023-03-13 15:30 16阅读 0赞

使用
    Java的concurrent包里面的CountDownLatch是一个非常实用的多线程控制工具类，其实可以把它看作一个计数器，只不过这个计数器的操作是原子操作，同时只能有一个线程去操作这个计数器，也就是同时只能有一个线程去减这个计数器里面的值。
    
    
    public CountDownLatch(int count)  构造器，实例化一个倒计时器，count指定计数个数
    public void countDown()   //计数减1
    public void await() throws InterruptedException   //阻塞等待直到计数器中的个数为0或者线程中断
     public boolean await(long timeout, TimeUnit unit)   //阻塞等待直到计数器的个数减为0，或者线程中断，或者等待了指定超时时间之后
     public long getCount()  //获取计数器当前的数量

**Demo**

public class CountDownLatchTest  implements Runnable{
        static final CountDownLatch  end = new CountDownLatch(10);
        static final CountDownLatchTest  demo =new CountDownLatchTest();
    
        @Override
        public void run() {
            try {
                Thread.sleep(new Random().nextInt(10)*1000);
                System.out.println("check complete "+Thread.currentThread().getName());
                end.countDown();  //计数器减1
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    
        public static void main(String[] args) {
            ExecutorService executor = Executors.newFixedThreadPool(10);
            for (int i = 0; i < 10 ; i++)
                executor.submit(demo);
    
            try {
                end.await();
                System.out.println("Fire!");
                executor.shutdown();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }