在Java多线程编程中，重入锁(ReentrantLock) 和信号量(Semaphore)是两个极其重要的并发控制工具。相信大部分读者都应该比较熟悉它们的使用(如果不清楚的小伙伴，赶快拿出书本翻阅一下)。
AbstractQueuedSynchronizer抽象同步队列简称AQS，它是实现同步器的基础组件，并发包中锁的底层就是使用AQS实现的。
闭锁（CountDownLatch）是Java多线程并发中的一种同步器，它是JDK内置的同步器。通过它可以定义一个倒计数器，当倒计数器的值大于0时，所有调用await方法的线程都会等待。而调用countDown方法则可以让倒计数器的值减一，当倒计数器值为0时所有等待的线程都将继续往下执行。
在同步代码块中，锁对象是谁，就用那个对象来调用wait和notify 为什么wait方法和notify方法需要定义在Object？ 因为所有的对象都是Object的子类对象，而所欲的对象都可以当做锁对象
AbstractQueuedSynchronizer抽象同步队列简称AQS，它是实现同步器的基础组件，并发包中锁的底层就是使用AQS实现的。另外，大多数开发者可能永远不会直接使用AQS，但是知道其原理对于架构设计还是很有帮助的。下面看下AQS的类图结构，如图所示。
日常中会有开启多个线程去并发执行任务，而主线程要等所有子线程执行完之后才能运行的需求。之前我们是使用Thread.join方法来实现的，过程如下：
synchronized 关键字是JDK官方人员用C++代码写的，在JDK6以前是重量级锁。Java大牛 Doug Lea对 synchronized 在并发编程条件下的性能表现不满意就自己写了个JUC，以此来提升并发性能，本文要讲的就是JUC并发包下的AbstractQueuedSynchronizer。
ReentrantLock 介绍 一个可重入的互斥锁，它具有与使用{synchronized}方法和语句访问的隐式监视器锁相同的基本行为和语义，但它具有可扩展的能力。 一个ReentrantLock会被最后一次成功锁定（lock）的线程拥有，在还没解锁（unlock）之前。当锁没有被其他线程拥有的话，一个线程执行『lock』方法将会返回，获取锁成功。一个方法将会立即的返回，如果当前线程已经拥有了这个锁。可以使用『isHeldByCurrentThread』和『getHoldCount』来检查当前线程是否持有
我将结合一个真实线上案例作为背景来展开讲解这一知识点。给大家讲清楚什么是同步工具类、适合的场景、解决了什么问题、各个实现方案的对比。希望对大家理解同步工具类这个知识点有所帮助。
本文的组织形式如下，主要会介绍到同步容器类，操作系统的并发工具，Java 开发工具包（只是简单介绍一下，后面会有源码分析）。同步工具类有哪些。
最近重新复习了一边并发的知识，发现自己之前对于并发的了解只是皮毛。这里总结以下Java并发需要掌握的点。
AQS全称AbstractQueuedSynchronizer，即抽象队列同步器。AQS是用来构建锁或者其他同步组件的基础框架，它使用一个整型的volatile变量state来维护同步状态，通过内置的FIFO队列来完成资源获取线程的排队工作。AQS为一系列同步器依赖于一个单独的原子变量state的同步器提供了一个非常有用的基础。
本篇内容基于JDK7，涉及Condition常用方法。 1.概述 Condition接口位于java.util.concurrent.locks包下，实现类有 AbstractQueuedLongSynchronizer.ConditionObject和 AbstractQueuedSynchronizer.ConditionObject。Condition将Object监视器方法(wait、notify和 notifyAll)分解成截然不同的对象，以便通过将这些对象与任意Lock实现组合使用。其中，Loc
在Java中除了synchronized关键字可以实现对象锁之外，java.util.concurrent中的Lock接口也可以实现对象锁。
Condition接口位于java.util.concurrent.locks包下，实现类有 AbstractQueuedLongSynchronizer.ConditionObject和 AbstractQueuedSynchronizer.ConditionObject。Condition将Object监视器方法(wait、notify和 notifyAll)分解成截然不同的对象，以便通过将这些对象与任意Lock实现组合使用。其中，Lock替代了synchronized方法的使用及作用，Condition替代了Object监视器方法的使用及作用。Condition的await方法代替Object的wait；Condition的signal方法代替Object的notify方法；Condition的signalAll方法代替Object的notifyAll方法。Condition实例在使用时需要绑定到一个锁上，可以通过newCondition方法获取Condition实例。Condition实现可以提供不同于Object监视器方法的行为和语义，比如受保证的通知排序，或者在执行通知时不需要保持一个锁。
AbstractQueuedSynchronizer 抽象同步队列简称 AQS ，它是实现同步器的基础组件， 并发包中锁的底层就是使用 AQS 实现的. 大多数开发者可能永远不会直接使用AQS ，但是知道其原理对于架构设计还是很有帮助的,而且要理解ReentrantLock、CountDownLatch等高级锁我们必须搞懂 AQS.
每个程序启动后拥有的第一个线程称为主线程，即GUI线程。QT中所有的组件类和几个相关的类只能工作在GUI线程，不能工作在次线程，次线程即工作线程，主要负责处理GUI线程卸下的工作。
CountDownLatch：用于协同控制一个或多个线程等待在其他线程中执行的一组操作完成，然后再继续执行
Java在java.util.concurrent.locks包中提供了一系列的显示锁类，其中最基础的就是Lock接口，该接口提供了几个常见的锁相关的操作。
之前的文章中学习了J.U.C中aqs的底层实现原理，这篇文学习一下J.U.C中提供的一些线程同步工具类。
CyclicBarrier 是JUC 所提供的比较好用且应用面十分广泛的一个并发工具。 CyclicBarrier 字面意思：循环 屏障，也就是一种循环可使用的同步屏障，可以一组线程等待都完成的时候放行。和CountDownLatch对比来看，就是CountDownLatch等待的是外部事件，而CyclicBarrier等待一组线程。虽然看上去功能是相似的，但是实现和使用上都存在一定的差异。
Java并发包（JUC）中提供了很多并发工具，这其中，很多我们耳熟能详的并发工具，譬如ReentrangLock、Semaphore，而它们的实现都用到了一个共同的基类--AbstractQueuedSynchronizer（抽象队列同步器），简称AQS。
源代码：Lib/threading.py 该模块在较低级别thread模块之上构建更高级别的线程接口。另请参见mutex和Queue模块。
知识体系图： 1、线程是什么？ 线程是进程中独立运行的子任务。 2、创建线程的方式 方式一：将类声明为 Thread 的子类。该子类应重写 Thread 类的 run 方法 方式二：声明实现 Runn
方式一：将类声明为 Thread 的子类。该子类应重写 Thread 类的 run 方法
3.不断重新尝试获取锁（当前结点为head的直接后继才会 尝试），如果获取失败，则会阻塞自己，直到被唤醒
1.java.util.concurrent包中的大多数同步器实现都是围绕着共同的基础行为，比如等待队列、条件队列、独占获取、共享获取等，而这些行为的抽象就是基于AbstractQueuedSynchronizer（简称AQS）实现的，AQS是一个抽象同步框架，可以用来实现一个依赖状态的同步器。
Java多线程在对共享资源进行访问时，如果不加以控制会存在线程安全问题，当我们使用多线程对共享资源访问时，通常会线程共享资源的进行访问线程数的控制：
CountDownLatch 介绍 CountDownLatch是一个同步协助类，允许一个或多个线程等待，直到其他线程完成操作集。 CountDownLatch使用给定的计数值（count）初始化。await方法会阻塞直到当前的计数值（count）由于countDown方法的调用达到0，在这之后（即，count为0之后）所有等待的线程都会被释放，并且随后对await方法的调用都会立即返回。这是一个一次性现象 ———— count不会被重置。如果你需要一个重置count的版本，那么请考虑使用CyclicBar
JUC 中 Semaphore 的使用与原理分析，Semaphore 也是 Java 中的一个同步器，与 CountDownLatch 和 CycleBarrier 不同在于它内部的计数器是递增的，那么，Semaphore 的内部实现是怎样的呢？
在java.util.concurrent包中，有两个很特殊的工具类，Condition和ReentrantLock，使用过的人都知道，ReentrantLock（重入锁）是jdk的concurrent包提供的一种独占锁的实现。它继承自Dong Lea的 AbstractQueuedSynchronizer（同步器），确切的说是ReentrantLock的一个内部类继承了AbstractQueuedSynchronizer，ReentrantLock只不过是代理了该类的一些方法，可能有人会问为什么要使用内部类在包装一层？ 我想是安全的关系，因为AbstractQueuedSynchronizer中有很多方法，还实现了共享锁，Condition(稍候再细说)等功能，如果直接使ReentrantLock继承它，则很容易出现AbstractQueuedSynchronizer中的API被无用的情况。
AbstractQueuedSynchronizer 抽象同步队列简称 AQS ，它是实现同步器的基础组件，
The same instance of Foo will be passed to three different threads. Thread A will call first(), thread B will call second(), and thread C will call third(). Design a mechanism and modify the program to ensure that second() is executed after first(), and third() is executed after second().
一、引言 在java中，对于任意一个java对象，它都拥有一组定义在java.lang.Object上监视器方法，包括wait()，wait(long timeout)，notify()，notifyAll()，这些方法配合synchronized关键字一起使用可以实现等待/通知模式。 同样，Condition接口也提供了类似Object监视器的方法，通过与Lock配合来实现等待/通知模式。Condition 将 Object 监视器方法（wait、notify 和 notifyAll）分解成截然不同的对象
使用 Python 可以编写多线程程序，注意，这并不是说程序能在多个 CPU 核上跑。如果你想这么做，可以看看关于 Python 并行计算的，比如官方 Wiki。
大家知道，我最近在招人，今天遇到个同学，他的源码看过一些，然后我就开始了AQS连环问。
CountDownLatch是一个很有用的工具，latch是门闩的意思，该工具是为了解决某些操作只能在一组操作全部执行完成后才能执行的情景。例如，小组早上开会，只有等所有人到齐了才能开；再如，游乐园里的过山车，一次可以坐10个人，为了节约成本，通常是等够10个人了才开。CountDown是倒数计数，所以CountDownLatch的用法通常是设定一个大于0的值，该值即代表需要等待的总任务数，每完成一个任务后，将总任务数减一，直到最后该值为0，说明所有等待的任务都执行完了，“门闩”此时就被打开，后面的任务可以继续执行。
每一个 Java 的高级程序员在体验过多线程程序开发之后，都需要问自己一个问题，Java 内置的锁是如何实现的？最常用的最简单的锁要数 ReentrantLock，使用它加锁时如果没有立即加成功，就会阻塞当前的线程等待其它线程释放锁之后再重新尝试加锁，那线程是如何实现阻塞自己的？其它线程释放锁之后又是如果唤醒当前线程的？当前线程是如何得出自己没有加锁成功这一结论的？本篇内容将会从根源上回答上面提到的所有问题
多个线程并发，协作来完成一件任务的过程。因为任务处理的需要，需控制某些线程等待另外一些线程执行完成任务的某些部分，然后继续执行。
我们刚刚学线程的时候，最常见的模拟各种延时用的就是 Thread.sleep 了，而在协程里面，对应的就是 delay。 sleep 让线程进入休眠状态，直到指定时间之后某种信号或者条件到达，线程就尝试恢复执行，而 delay 会让协程挂起，这个过程并不会阻塞 CPU，甚至可以说从硬件使用效率上来讲是“什么都不耽误”，从这个意义上讲 delay 也可以是让协程休眠的一种很好的手段。
Java 并发编程是整个 Java 开发体系中最难以理解但也是最重要的知识点，也是各类开源分布式框架（如 ZooKeeper、Kafka、Spring Cloud、Netty 等）中各个并发组件实现的基础。J.U.C 并发包，即 java.util.concurrent 包，大大提高了并发性能，是 JDK 的核心工具包，是 JDK 1.5 之后，由 Doug Lea 实现并引入。而 AQS 被认为是 J.U.C 的核心。
上一次我们介绍了ReentrantLock和Synchronized的异同，这次我们来讲讲concurrent包下面的另外一个类，Condition。 Java的 java.util.concurrent 包提供了很多处理并发场景的类，Condition 就是其中一个。
在我们并发编程的文章一开始，我们都是在围绕着线程安全问题叙述它的解决方案，在前面的文章中我们曾提到过CAS无锁机制、synchronized关键字等多种解决方案，在其中CAS机制属于乐观锁类型，synchronized关键字属于悲观锁类型，而我们本章要谈到的基于AQS实现的ReetrantLock也是属于悲观锁类型的实现。但是它与我们之前聊的synchronized并不相同，synchronized关键字属于隐式锁，锁的获取和释放都是隐式的，且不需要开发人员干预。而我们本章要讲的则是显式锁，即锁的获取和释放都需要我们手动编码实现。在JDK1.5时，官方在Java.uitl.concurrent并发包中添加了Lock锁接口，该接口中定义了lock()获取锁和unlock()释放锁两个方法对显式锁的加锁与解锁操作提供了支持。显式锁的使用方式如下：
1、并发容器及安全共享策略总结，并发容器J.U.C(即java.util.concurrent)。J.U.C同步器AQS。
CountDownLatch是我们常用的并发工具，主要用于倒数计数等场景，如在zookeeper连接管理中用于初始化连接数。CountDownlatch是AbstractQueueSynchronizer的共享模式实现。实际上，我们可以理解AQS为什么没有将所有方法定义为abstract方法，这是因为子类可以根据共享还是独占模式来自由选择需要实现的方法。 CountDownLatch的类结构如下：
在java中，为了配合ReentrantLock等Lock的实现类实现锁的多条件等待，为此java设计了Condition接口。在AQS中的主要结构如下：
并发执行的进程数目并不是由CPU数目制约的。 操作系统将CPU的时间片分配给每一个进程，给人并行处理的感觉。
这个场景是一等多的场景，比如去医院看病，检查完一项，盖一个章，盖好了再去主治医生进行下一步，或者拼多多，需要等其他人操作完，比如5个人拼团，你得等其他4个人执行countDown，才能拼单成功
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
