三种常用的辅助工具类


三种常用的辅助工具类

CountDownLatch

三种常用的辅助工具类

 

  • 是一个执行减法操作的辅助计数器

//计数器
public class CountDownLatchTest {
   public static void main(String[] args) throws InterruptedException {
       //总数是六,必须在执行任务时再使用
       CountDownLatch countDownLatch = new CountDownLatch(6);
       for (int i = 0; i <=6 ; i++) {
           new Thread(()->{
               System.out.println(Thread.currentThread().getName()+" 开门");
               countDownLatch.countDown(); //执行-1操作
          },String.valueOf(i)).start();
      }
       countDownLatch.await();//等待计数器归零,再执行向下操作
       System.out.println("关门");
  }
}

CyclicBarrier

三种常用的辅助工具类

 

//加法计数器
public class CyclicBarrierTest {
   public static void main(String[] args) {
       CyclicBarrier cyclicBarrier = new CyclicBarrier(6,()->{
           System.out.println("线程执行完毕");
      });
       for (int i = 0; i <=6 ; i++) {
           final  int temp=i;
           new Thread(()->{ //lambda表达式不能直接获取for循环中的变量,需要通过final类型转换
               System.out.println(Thread.currentThread().getName()+"线程执行了"+temp);
               try {
                   cyclicBarrier.await();
              } catch (InterruptedException e) {
                   e.printStackTrace();
              } catch (BrokenBarrierException e) {
                   e.printStackTrace();
              }
          },String.valueOf(i)).start();
      }
  }
}

Semaphore

三种常用的辅助工具类

 

//运行许可
public class SemaphoreTest {
   public static void main(String[] args) {
       //线程数量:抽象的看成停车位
       Semaphore semaphore = new Semaphore(3); //相当于存在三个停车位
       for (int i = 0; i <=6 ; i++) {
           new Thread(()->{
               try {
                   semaphore.acquire();//获得,假设线程已满,会等待其他线程被释放为止
                   System.out.println(Thread.currentThread().getName()+"抢到了车位");
                   TimeUnit.SECONDS.sleep(2);//线程休眠两秒
                   System.out.println(Thread.currentThread().getName()+"离开了车位");
              } catch (InterruptedException e) {
                   e.printStackTrace();
              }finally{
                   semaphore.release(); //释放线程,会将当前的释放量+1,然后唤醒等待
              }
          },String.valueOf(i)).start();
      }
  }
}

作用:

  • 多个共享资源互斥使用

  • 并发限流,控制最大线程数

原创文章,作者:Carrie001128,如若转载,请注明出处:https://blog.ytso.com/tech/pnotes/245226.html

(0)
上一篇 2022年4月18日 05:14
下一篇 2022年4月18日 05:24

相关推荐

发表回复

登录后才能评论