JUC三大辅助类得使用和介绍

1.CountDownLatch 减少计数
CountDownLatch主要有两个方法，当一个或多个线程调用await方法时，这些线程会阻塞。
其它线程调用countDown方法会将计数器减1(调用countDown方法的线程不会阻塞)，
当计数器的值变为0时，因await方法阻塞的线程会被唤醒，继续执行。

例子:离开高考考场得肯定是监考老师,不能让考生留在考场中,必须等最后一名考生离开考场,然后锁门关灯.

#错误代码示例,若需要正确代码只需要把代码中注释的代码放开则为正确代码
public class LockTestC {
    public static void main(String[] args) throws InterruptedException {
//        CountDownLatch count = new CountDownLatch(7);
        for (int i = 0;i < 7;i++){
            final int temp = i;
            new Thread(()->{
//                count.countDown();
                System.out.println("同学:"+temp+"离开教室");
            },String.valueOf(i)).start();
        }
//        count.await();
        System.out.println("main******方法离开");
    }
}

错误示例:

image.png

正确示例:

image.png

2.CyclicBarrier 循环栅栏 CyclicBarrier 的字面意思是可循（Cyclic）使用的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活。线程进入屏障通过CyclicBarrier的await()方法。
例子:开会得时候必须等到所有人在才能开会,不能缺席.跟集齐七颗龙珠召唤神龙一样,缺一不可.

public class CyclicBarrierDemo
{
  private static final int NUMBER = 7;
  
  public static void main(String[] args)
  {
     //CyclicBarrier(int parties, Runnable barrierAction) 
     
     CyclicBarrier cyclicBarrier = new CyclicBarrier(NUMBER, ()->{System.out.println("*****集齐7颗龙珠就可以召唤神龙");}) ;
     
     for (int i = 1; i <= 7; i++) {
       new Thread(() -> {
          try {
            System.out.println(Thread.currentThread().getName()+"\t 星龙珠被收集 ");
            cyclicBarrier.await();
          } catch (InterruptedException | BrokenBarrierException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
       
       }, String.valueOf(i)).start();
     }
     
 
  }
}

3.Semaphore 信号灯
在信号量上我们定义两种操作：
acquire（获取）当一个线程调用acquire操作时，它要么通过成功获取信号量（信号量减1），要么一直等下去，直到有线程释放信号量，或超时。
release（释放）实际上会将信号量的值加1，然后唤醒等待的线程。

信号量主要用于两个目的，一个是用于多个共享资源的互斥使用，另一个用于并发线程数的控制。

public class SemaphoreDemo
{
  public static void main(String[] args)
  {
     Semaphore semaphore = new Semaphore(3);//模拟3个停车位
     
     for (int i = 1; i <=6; i++) //模拟6部汽车
     {
       new Thread(() -> {
          try 
          {
            semaphore.acquire();
            System.out.println(Thread.currentThread().getName()+"\t 抢到了车位");
            TimeUnit.SECONDS.sleep(new Random().nextInt(5));
            System.out.println(Thread.currentThread().getName()+"\t------- 离开");
          } catch (InterruptedException e) {
            e.printStackTrace();
          }finally {
            semaphore.release();
          }
       }, String.valueOf(i)).start();
     }
     
  }
}

最后编辑于：2020.07.09 14:37:29