并发

InheritableThreadLocal

InheritableThreadLocal继承于ThreadLocal,功能与ThreadLocal差不多;不同的是, InheritableThreadLocal 可以在子线程中获取到父线程设置的值。 ` public class ThreadContextChild { private

理解CAS

简介 众所周知,synchronize能够保证数据操作的原子性,从而实现同步效果。但是这种通过多个线程竞争锁的方式其效率会比较差,于是java另外实现了另一种无锁的却能保证数据操作原子性的方式——CAS(Compare-and-swap)。 CAS的原理 Compare-and-swap,是一个针对

并发工具类的同步器

本文介绍JDK中并发工具类的各种同步器,倒计时门闩(countdown latch)、同步屏障(cyclic barrier)、交换器(exchanger)、信号量(semaphore)以及phaser同步器。 一、倒计时门闩 java.util.concurrent.CountDownLatch同

关于join()的一个小坑

很多情况下,主线程创建并启动子线程,如果子线程中要进行比较耗时的运算,并且希望主线程等待子线程执行完毕之后再执行。那么就可以使用join()方法,它是线程类Thread的一个用于等待线程对象销毁的方法,底层是wait()方法。 join()的使用比较简单,但是有个小坑需要注意一下。 下面看这个例子:

通过管道进行线程间通信

管道流(pipeStream)是一种特殊的流,用于在不同线程间直接传送数据。一个线程发送数据到输出管道,另一个线程从输入管道中读数据。通过管道,实现不同线程间的通信,而无须借助类似共享变量、临时文件之类的东西。 在java的JDK中提供了4个类来使线程间可以进行通信: ` 管道字节流 Piped

回顾经典:生产者与消费者模式

等待/通知模式最经典的案例就是“生产者/消费者”模式。但此模式在使用上有几种“变形”,还有一些小的注意事项,但原理上都是基于wati/notify的。《Java多线程编程核心技术》 案例——1对1的生产者与消费者模式 创建一个消费者和一个生产者,生产者每生产一个产品,消费者就会去消费这个产品。在没有

线程通信基础:wait和notify

wait() 方法wait()的作用是使当前执行代码的线程进行等待,它是Object类的方法,用来将当前线程置入“预执行队列”中,并且在wait()所在的代码行处停止执行,直到接到通知或被中断为止。 在调用wait()之前,线程必须获得该对象的对象级别锁,即只能在同步方法或同步块中调用wait()方

synchronize可以锁住一个方法?

记得有一次在面试一个实习生的时候,闻到了一个synchronize的相关问题,他提到“synchronize通过锁住一个方法或者一段代码实现同步效果”。这句话从表面上看其实也没有什么问题,毕竟从代码上看就是这么回事—— ` public synchronized void run() {

volatile关键字与内存模型

对volatile关键字的理解,与java的内存模型的概念是分不开的。 从内存模型说起 java中有个概念叫内存模型,大体是这样的一种结构: [ ]()java内存模型 java内存模型规定了所有的变量都存储在主内存中,即是虚拟机内存的一部分。 每条线程拥有自己的工作内存,线程不能直接读写主内存中的