Java 同步工具类CountDownLatch相当于一个计数器，假设一个方法，等待一个计数器从初始值5变为0，每使用一次countdown()方法，计数器的值减少1，当计数器的值为0时，触发某件事。 使用很简单： public class LatchTest {// 计数器设置为5private static CountDownLatch latch = new CountDownLatch(5);public void m() {try {Thread.sleep(2000L);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thre...
Semaphore 可以理解为一个阈值，正在进行的操作数量不能超过此阈值，可以用来限制资源的访问，或者控制某个队列中对象的个数。 public class SemaphoreTest {private Semaphore semaphore = new Semaphore(2);public void m() {try {System.out.println(Thread.currentThread().getName()+" started");semaphore.acquire();Thread.sleep((int) (Math.random() * 2000));} catch (InterruptedException e) {e.printStackTrace();} f...
CyclicBarrier 用来阻塞一组线程，等待线程完成后才开始某件事情。 例如，开启5个线程，每个线程使用await方法开始阻塞，等待5个线程都完成，才开始执行await方法后面的代码。 public class CyclicBarrierTest {private static CyclicBarrier barrier = new CyclicBarrier(5);static class Writer extends Thread {private CyclicBarrier cyclicBarrier;public Writer(CyclicBarrier cyclicBarrier) {this.cyclicBarrier = cyclicB...
文章目录 引言1 隐藏在并发包中的管程1.1 再造管程的理由1.2 如何保证可见性1.3 什么是可重入锁1.4 公平锁与非公平锁1.5 用锁的最佳实践 2 Dubbo如何用管程实现异步转同步2.1 同步与异步2.2 Dubbo源码分析引言 Java SDK并发包内容很丰富，包罗万象，但是我觉得最核心的还是其对管程的实现。因为理论上利用管程，你几乎可以实现并发包里所有的工具类。在前面 管程——并发编程的万能钥匙》中我们提到过在并发编程领域，有两大核心问...
Java 提供了另外一种锁机制，显示锁，ReentrantLock，提供了比 synchronized 更高级的功能，包含lock(), tryLock()，lockInterruptibly()，unlock(),newCondition()方法。 简单使用栗子： public class ReentrantLockTest {Lock lock = new ReentrantLock();public void test1() {try {// 线程1获得锁，每两秒输出一次i，10秒后，解锁lock.lock();for (int i=0; i<5; i++) {Thread.sleep(2000L);System.out.println(i);}} catch (I...
引言 Semaphore，现在普遍翻译为“信号量”，以前也曾被翻译成“信号灯”，因为类似现实生活里的红绿灯，车辆能不能通行，要看是不是绿灯。同样，在编程世界里，线程能不能执行，也要看信号量是不是允许。 信号量是由大名鼎鼎的计算机科学家迪杰斯特拉（Dijkstra）于1965年提出，在这之后的15年，信号量一直都是并发编程领域的终结者，直到1980年管程被提出来，我们才有了第二选择。目前几乎所有支持并发编程的语言都支持信号量机制...
引言 并发编程这个技术领域已经发展了半个世纪了，相关的理论和技术纷繁复杂。那有没有一种核心技术可以很方便地解决我们的并发问题呢？这个问题如果让我选择，我一定会选择管程技术。Java语言在1.5之前，提供的唯一的并发原语就是管程，而且1.5之后提供的SDK并发包，也是以管程技术为基础的。除此之外，C/C++、C#等高级语言也都支持管程。 可以这么说，管程就是一把解决并发问题的万能钥匙。 什么是管程 不知道你是否曾思考过这个...
文章目录 引言1 Java线程的生命周期1.1 通用的线程生命周期1.2 Java中线程的生命周期 2 创建多少线程才是合适的2.1 为什么要使用多线程？2.2 多线程的应用场景2.3 创建多少线程合适 3 为什么局部变量是线程安全的3.1 方法是如何被执行的3.2 局部变量存哪里3.3 调用栈与线程3.4 线程封闭引言 在Java领域，实现并发程序的主要手段就是多线程。线程是操作系统里的一个概念，虽然各种不同的开发语言如Java、C#等都对其进行了封装，但是...
对象的共享 书接上篇，我们了解了如何通过同步来避免多个线程在同一时刻访问相同的数据，而本篇将介绍如何共享和发布对象，从而使它们能够安全地由多个线程同时访问。 1. 可见性 线程安全性的内容，让我们知道了同步代码块和同步方法可以确保以原子的方式执行操作。但如果你认为关键字 synchronized 只能用于实现原子性或者确定“临界区（Critical Section）”，那就大错特错了。同步还有一个重要的方面：内存可见性（Memory Visib...
简介 在并发编程中我们有时候需要使用线程安全的队列。如果我们要实现一个线程安全的队列有两种实现方式一种是使用阻塞算法，另一种是使用非阻塞算法。使用阻塞算法的队列可以用一个锁（入队和出队用同一把锁）或两个锁（入队和出队用不同的锁）等方式来实现，而非阻塞的实现方式则可以使用循环CAS的方式来实现，下面我们一起来研究下Doug Lea是如何使用非阻塞的方式来实现线程安全队列ConcurrentLinkedQueue的。 ConcurrentLinked...
基础知识 为什么要使用并发编程 提升多核CPU的利用率：一般来说一台主机上的会有多个CPU核心，我们可以创建多个线程，理论 上讲操作系统可以将多个线程分配给不同的CPU去执行，每个CPU执行一个线程，这样就提高了 CPU的使用效率，如果使用单线程就只能有一个CPU核心被使用。 比如当我们在网上购物时，为了提升响应速度，需要拆分，减库存，生成订单等等这些操作，就可 以进行拆分利用多线程的技术完成。面对复杂业务模型，并行程序...
不考虑多线程并发的情况下，容器类一般使用ArrayList、HashMap等线程不安全的类，效率更高。在并发场景下，常会用到ConcurrentHashMap、ArrayBlockingQueue等线程安全的容器类，虽然牺牲了一些效率，但却得到了安全。上面提到的线程安全容器都在java.util.concurrent包下，这个包下并发容器不少，今天全部翻出来鼓捣一下。仅做简单介绍，后续再分别深入探索。并发容器介绍ConcurrentHashMap：并发版HashMapCopyOnWriteArrayList：并...
并发编程的三大特性 java并发编程的优点和缺点 并行和并发的区别以及多线程的实现
文章目录 ThreadLocal的使用一、介绍1. 作用2. 特点 二、代码示例ThreadLocal的使用 一、介绍 1. 作用可以解决多线程的数据安全问题，将当前线程关联一个数据（可以是普通变量，可以是对象，也可以是数组，集合） 原理在共享内存中提供该变量的副本，每个线程都可以独立的使用自己的副本，而不会影响其他线程所对应的副本 图示 2. 特点 ThreadLocal 可以为当前线程关联一个数据；它可以像 Map 一样存取数据，但是只需要存取va...
本文部分摘自《Java 并发编程的艺术》CountDownLatch CountDownLatch 允许一个或多个线程等待其他线程完成操作。假设现有一个需求：我们需要解析一个 Excel 里多个 sheet 的数据，此时可以考虑使用多线程，每个线程解析一个 sheet 的数据，等到所有的 sheet 都解析完之后，程序需要提示解析完成。在这个需求中，要实现主线程等待所有线程完成 sheet 的解析操作，最简单的做法就是使用 join() 方法 public class JoinCountDownLatch...