摘要：中提供了几个比较常用的并发工具类，比如。是一个同步工具类，它允许一个或多个线程一直等待，直到其他线程的操作执行完毕再执行。从命名可以解读到是倒数的意思，类似于我们倒计时的概念。
JUC中提供了几个比较常用的并发工具类，比如CountDownLatch、CyclicBarrier、Semaphore。 其实在以前我们 课堂的演示代码中，或多或少都有用到过这样一些api，接下来我们会带大家去深入研究一些常用的api。 CountDownLatch
countdownlatch是一个同步工具类，它允许一个或多个线程一直等待，直到其他线程的操作执行完毕再执行。从 命名可以解读到countdown是倒数的意思，类似于我们倒计时的概念。 countdownlatch提供了两个方法，一个是countDown，一个是await， countdownlatch初始化的时候需要传入一 个整数，在这个整数倒数到0之前，调用了await方法的程序都必须要等待，然后通过countDown来倒数。
public static void main(String[] args) throws InterruptedException {
CountDownLatch countDownLatch=new CountDownLatch(3);
new Thread(()->{
countDownLatch.countDown();
},"t1").start();
new Thread(()->{
countDownLatch.countDown();
},"t2").start();
new Thread(()->{
countDownLatch.countDown();
},"t3").start();
countDownLatch.await();
System.out.println("所有线程执行完毕");
}
从代码的实现来看，有点类似join的功能，但是比join更加灵活。CountDownLatch构造函数会接收一个int类型的 参数作为计数器的初始值，当调用CountDownLatch的countDown方法时，这个计数器就会减一。 通过await方法去阻塞去阻塞主流程
使用场景
1. 通过countdownlatch实现最大的并行请求，也就是可以让N个线程同时执行，这个我也是在课堂上写得比较多 的
2. 比如应用程序启动之前，需要确保相应的服务已经启动，比如我们之前在讲zookeeper的时候，通过原生api连 接的地方有用到countDownLatch 源码分析
CountDownLatch类存在一个内部类Sync，上节课我们讲过，它是一个同步工具，一定继承了 AbstractQueuedSynchronizer。很显然，CountDownLatch实际上是是使得线程阻塞了，既然涉及到阻塞，就一 定涉及到AQS队列 await
await函数会使得当前线程在countdownlatch倒计时到0之前一直等待，除非线程别中断；从源码中可以得知await 方法会转发到Sync的acquireSharedInterruptibly
方法
public void await() throws InterruptedException { sync.acquireSharedInterruptibly(1); } acquireSharedInterruptibly
这块代码主要是判断当前线程是否获取到了共享锁; 上一节课提到过，AQS有两种锁类型，一种是共享锁，一种是 独占锁，在这里用的是共享锁； 为什么要用共享锁，因为CountDownLatch可以多个线程同时通过。
public final void acquireSharedInterruptibly(int arg)
throws InterruptedException {
doAcquireSharedInterruptibly
获取共享锁
if (Thread.interrupted()) //判断线程是否中断
throw new InterruptedException();
if (tryAcquireShared(arg) < 0) //如果等于0则返回1，否则返回-1，返回-1表示需要阻塞
doAcquireSharedInterruptibly(arg);
} 在这里，state的意义是count，如果计数器为0，表示不需要阻塞，否则，只有在满足条件的情况下才会被唤醒
doAcquireSharedInterruptibly
获取共享锁
private void doAcquireSharedInterruptibly(int arg)
throws InterruptedException {
final Node node = addWaiter(Node.SHARED); //创建一个共享模式的节点添加到队列中 boolean failed = true;
try {
for (;;) { //自旋等待共享锁释放，也就是等待计数器等于0。
final Node p = node.predecessor(); //获得当前节点的前一个节点
if (p == head) {
int r = tryAcquireShared(arg);//就判断尝试获取锁
if (r >= 0) {//r>=0表示计数器已经归零了，则释放当前的共享锁
setHeadAndPropagate(node, r);
p.next = null; // help GC
failed = false;
return;
}
} //当前节点不是头节点，则尝试让当前线程阻塞，第一个方法是判断是否需要阻塞，第二个方法是阻塞
if (shouldParkAfterFailedAcquire(p, node) &&
parkAndCheckInterrupt())
throw new InterruptedException();
}
} finally {
if (failed)
cancelAcquire(node);
}
}
待续。。。。。。。。。
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/72632.html
摘要：在上篇文章实现简单爬虫框架单任务版爬虫中我们实现了一个简单的单任务版爬虫，对于单任务版爬虫，每次都要请求页面，然后解析数据，然后才能请求下一个页面。在上篇文章Golang实现简单爬虫框架（2）——单任务版爬虫中我们实现了一个简单的单任务版爬虫，对于单任务版爬虫，每次都要请求页面，然后解析数据，然后才能请求下一个页面。整个过程中，获取网页数据速度比较慢，那么我们就把获取数据模块做成并发执行。在...
摘要：在上篇文章实现简单爬虫框架单任务版爬虫中我们实现了一个简单的单任务版爬虫，对于单任务版爬虫，每次都要请求页面，然后解析数据，然后才能请求下一个页面。在上篇文章Golang实现简单爬虫框架（2）——单任务版爬虫中我们实现了一个简单的单任务版爬虫，对于单任务版爬虫，每次都要请求页面，然后解析数据，然后才能请求下一个页面。整个过程中，获取网页数据速度比较慢，那么我们就把获取数据模块做成并发执行。在...
摘要：如何使用优化高并发场景写库或者耗时计算在的接口中使用消息队列，把要入库的数据写入的类型中。高容错子进程异常奔溃时，主进程将重建子进程。高性能多进程运行，充分利用多个并行计算，性能强劲。 经常在群里听到一些朋友问：TP 的项目怎么迁移到 mixphp 来处理高并发，我通常都是回复需要重写，可是一个开发很久的 TP 项目，代码量巨大，又怎么可能会花大量时间成本来重写呢？ 那么为何我们不尝试...
摘要：有三种状态运行关闭终止。类类，提供了一系列工厂方法用于创建线程池，返回的线程池都实现了接口。线程池的大小一旦达到最大值就会保持不变，在提交新任务，任务将会进入等待队列中等待。此线程池支持定时以及周期性执行任务的需求。 这是java高并发系列第19篇文章。 本文主要内容 介绍Executor框架相关内容 介绍Executor 介绍ExecutorService 介绍线程池ThreadP...
摘要：线程的启动与销毁都与本地线程同步。操作系统会调度所有线程并将它们分配给可用的。框架的成员主要成员线程池接口接口接口以及工具类。创建单个线程的接口与其实现类用于表示异步计算的结果。参考书籍并发编程的艺术方腾飞魏鹏程晓明著 在java中，直接使用线程来异步的执行任务，线程的每次创建与销毁需要一定的计算机资源开销。每个任务创建一个线程的话，当任务数量多的时候，则对应的创建销毁开销会消耗大量...
摘要：新增新增模型方法，主动刷新数据表结构缓存。分布式并发模型是什么是一种与共享内存对应的并发模型，具有资源独占性。都分布在不同的机器上。 One - 极简 . 高性能 . 松耦合 . 分布式 . 可运行于多种环境(cli,apache/php-fpm,swoole) 码云: https://gitee.com/vicself/onegithub: https://github.com/li...
阅读 3047·2023-04-26 02:27
阅读 2764·2021-11-22 13:54
阅读 902·2021-11-12 10:36
阅读 3755·2021-10-09 09:44
阅读 3179·2021-10-09 09:41
阅读 1224·2021-09-22 10:02
阅读 2833·2019-08-30 15:56
阅读 3107·2019-08-30 11:02
