以下是为您整理出来关于【java并发编程】合集内容，如果觉得还不错，请帮忙转发推荐。
1进程/线程是什么？ 进程是“执行中的程序”，进行资源分配和调度的独立单位，线程是进程的实体，一个进程可以拥有多个线程，线程的上下文切换比进程要快，线程之间共享地址空间和其他资源。2线程状态？ Thread 的源码中定义了6种状态：new（新建）、runnnable（可运行）、blocked（阻塞）、waiting（等待）、time waiting （定时等待）和 terminated（终止）。线程状态转换如下图所示：join() 在线程中调用另一个线程的 join() 方...
download：Java并发编程高阶技术高性能并发框架源码解析与实战 本课程从高性能并发框架Disruptor核心知识开始学习，之后带你深度剖析底层源码，整合Netty实战，最后进行架构设计，带你彻底精通一个如此优秀的开源框架，让你无论是应对实际工作、还是面试晋升，都能游刃有余。 适合人群 1.Java中高级工程师 2.想彻底掌握一个优秀的开源框架的工程师 3.想进一步提高并发编程能力的工程师 4.想提升技术深度和面试高薪的工程师（如果没...
download：Java并发编程高阶技术高性能并发框架源码解析与实战 本课程从高性能并发框架Disruptor核心知识开始学习，之后带你深度剖析底层源码，整合Netty实战，最后进行架构设计，带你彻底精通一个如此优秀的开源框架，让你无论是应对实际工作、还是面试晋升，都能游刃有余。 适合人群 1.Java中高级工程师 2.想彻底掌握一个优秀的开源框架的工程师 3.想进一步提高并发编程能力的工程师 4.想提升技术深度和面试高薪的工程师（如果没...
ReentrantReadWriteLock 允许多个读操作同时进行，但是只允许一个写操作同时进行，在某些情况下，可以实现更高的并发性。 举个栗子： public class ReadAndWriteLockTest {static {System.out.println("static "+Thread.currentThread().isDaemon());}public static void main(String[] args) {//或者等所有的非守护线程结束后JVM终止运行System.out.println(Thread.currentThread().isDaemon());final Queue3 q3 = new Queue3();f...
ThreadLocal 通过get和set方法，为每个使用该变量的线程提供一个独立的副本。 栗子说明问题： public class ThreadLocalTest {public static void main(String[] args) {final A a = new A();final B b = new B();for(int i = 0 ; i < 15 ; i ++) {final String resouce1 = "线程-" + i;final String resouce2 = " value = (" + i + ")";final ThreadLocal<String> threadLocal = new ThreadLocal<String>();final String value = ...
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...
引言 前面的文章中我们介绍了管程和信号量这两个同步原语在Java语言中的实现，理论上用这两个同步原语中任何一个都可以解决所有的并发问题。那Java SDK并发包里为什么还有很多其他的工具类呢？原因很简单：分场景优化性能，提升易用性。 今天我们就介绍一种非常普遍的并发场景：读多写少场景。实际工作中，为了优化性能，我们经常会使用缓存，例如缓存元数据、缓存基础数据等，这就是一种典型的读多写少应用场景。缓存之所以能提升...
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...
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...