-
-
Java并发包源码解析
收藏Java并发包(java.util.concurrent)源码解析。 主要基于jdk1.6。 更高jdk版本的并发包源码解析也会陆续加进来。
分享到：
最近更新文章
Jdk1.8 JUC源码增量解析(2)-atomic-LongAdder和LongAccumulator
Jdk1.8 JUC源码增量解析(2)-atomic-LongAdder和LongAccumulator
作者：大飞
功能简介：
LongAdder是jdk1.8提供的累加器，基于Striped64实现。它常用于状态采集、统计等场景。AtomicLong也可以用于这种场景，但在线程竞争激烈的情况下，LongAdder要比AtomicLong拥有更高的吞吐量，但会耗费更多的内存空间 ...
Jdk1.8 JUC源码增量解析(1)-atomic-Striped64
Jdk1.8 JUC源码增量解析(1)-atomic-Striped64
作者：大飞
功能简介：
Striped64是jdk1.8提供的用于支持如Long累加器，Double累加器这样机制的基础类。
Striped64的设计核心思路就是通过内部的分散计算来避免竞争(比如多线程CAS操作时的竞争)。
Striped64内部包含一个基础值和一个单元哈希表。没有竞争的情况下，要累加 ...
Jdk1.7 JUC源码增量解析(6)-Phaser
Jdk1.7 JUC源码增量解析(6)-Phaser
作者：大飞
功能简介：
Phaser是jdk1.7提供的类似于CyclicBarrier和CountDownLatch的同步机制。
它支持更灵活的使用方式：1.使用过程中可以随时注册和注销参与者；2.不同于CyclicBarrier，分离出"到达"和"等待"机制；3.支持结束，默认情况 ...
Jdk1.7 JUC源码增量解析(5)-ForkJoin-ForkJoin框架其他过程及方法
Jdk1.7 JUC源码增量解析(5)-ForkJoin-ForkJoin框架其他过程及方法
作者：大飞
概述：
这篇会看一下ForkJoin框架的其他过程，如取消任务、关闭Pool，以及前面没分析到一些方法。
源码分析：
前面我们看到，ForkJoinTask本身也是Future的实现，所以也会有取消过程，看下实现：
public boole ...
Jdk1.7 JUC源码增量解析(4)-ForkJoin-ForkJoin任务的fork/join过程
Jdk1.7 JUC源码增量解析(4)-ForkJoin-ForkJoin任务的fork/join过程
作者：大飞
概述：
这篇通过分析一个ForkJoin任务的执行过程来分析ForkJoin的相关代码，主要侧重于分裂(fork)/合并(join)过程。
源码分析：
还是先看一个代码示例，这个示例介绍篇出现过，这里只贴出任务代码：
publi ...
Jdk1.7 JUC源码增量解析(3)-ForkJoin-非ForkJoin任务的执行过程
Jdk1.7 JUC源码增量解析(3)-ForkJoin-非ForkJoin任务的执行过程
作者：大飞
概述：
这篇通过分析一个非ForkJoin(Runnable或者Callable)任务的执行过程来分析ForkJoin的相关代码，注意这里说的非ForkJoin任务实际上也是ForkJoinTask，只是没有分裂(fork)/合并(join)过程。
源码分析：
...
Jdk1.7 JUC源码增量解析(2)-ForkJoin-框架概览
Jdk1.7 JUC源码增量解析(2)-ForkJoin-框架概览
作者：大飞
ForkJoin框架是什么？
ForkJoin框架是jdk1.7提供的一个并行计算框架。
ForkJoin框架能干什么？
首先ForkJoin框架是针对一些符合ForkJoin模型的任务而设计的，那什么是ForkJoin模型呢？看个图先：
...
Jdk1.7 JUC源码增量解析(1)-FutureTask
Jdk1.7 JUC源码增量解析(1)-FutureTask
作者：大飞
功能简介：
FutureTask是一种异步任务(或异步计算)，举个栗子，主线程的逻辑中需要使用某个值，但这个值需要负责的运算得来，那么主线程可以提前建立一个异步任务来计算这个值(在其他的线程中计算)，然后去做其他事情，当需要这个值的时候再通过刚才建立的异步任务来获取这个值，有点并行的意思，这样可以缩短整个 ...
Jdk1.6 JUC源码解析(27)-Exchanger
Jdk1.6 JUC源码解析(27)-Exchanger
作者：大飞
功能简介：
Exchanger是一种线程间安全交换数据的机制。可以和之前分析过的SynchronousQueue对比一下：线程A通过SynchronousQueue将数据a交给线程B；线程A通过Exchanger和线程B交换数据，线程A把数据a交给线程B，同时线程B把数据b交给线程A。可见，Synchronou ...
Jdk1.6 JUC源码解析(26)-ConcurrentSkipListMap、ConcurrentSkipListSet
Jdk1.6 JUC源码解析(26)-ConcurrentSkipListMap、ConcurrentSkipListSet
作者：大飞
功能简介：
ConcurrentSkipListMap是一种线程安全的有序的Map。一般我们使用有序Map，不要求线程安全的情况下，可以使用TreeMap，要求线程安全的话，就可以使用ConcurrentSkipListMap。
Concu ...
Jdk1.6 JUC源码解析(25)-ConcurrentHashMap
Jdk1.6 JUC源码解析(25)-ConcurrentHashMap
作者：大飞
功能简介：
ConcurrentHashMap是一种线程安全的HashMap。相对于HashTable和Collections.synchronizedMap()，Concurre ...
Jdk1.6 JUC源码解析(24)-ConcurrentLinkedQueue
Jdk1.6 JUC源码解析(24)-ConcurrentLinkedQueue
作者：大飞
功能简介：
ConcurrentLinkedQueue是一种基于单向链表实现的无界的线程安全队列。队列中的元素遵循先入先出(FIFO)的规则。新元素插入到队列的尾部，从队列头部取出元素。
ConcurrentLinkedQueue内部采用一种wait-free(无等待)算法来实现。
...
Jdk1.6 JUC源码解析(23)-CopyOnWriteArrayList、CopyOnWriteArraySet
Jdk1.6 JUC源码解析(23)-CopyOnWriteArrayList、CopyOnWriteArraySet
作者：大飞
功能简介：
CopyOnWriteArrayList是一种线程安全的ArrayList。顾名思义，有写操作时 ...
Jdk1.6 JUC源码解析(22)-LinkedBlockingDeque
Jdk1.6 JUC源码解析(22)-LinkedBlockingDeque
作者：大飞
功能简介：
LinkedBlockingDeque是一种基于双向链表实现的有界的(可选的，不指定默认int最大值)阻塞双端队列。
双端队列一般适用于工作密取模式，即每个消费者都拥有自己的双端队列，如果某个消费者完成了自己队列的全部任务，可以到其他消费者双端队列尾部秘密获取 ...
Jdk1.6 JUC源码解析(21)-ExecutorCompletionService
Jdk1.6 JUC源码解析(21)-ExecutorCompletionService
作者：大飞
功能简介：
ExecutorCompletionService用于执行一批任务，然后按照任务执行完成的顺序来获取任 ...
Jdk1.6 JUC源码解析(20)-Executors
Jdk1.6 JUC源码解析(20)-Executors
作者：大飞
功能简介：
Executors是JUC包提供的一个工具性质的帮助类，它针对ExecutorService、ScheduledExecutorService、ThreadFactory和Callable提供了一系列工厂方法和工具方法。
源码分析：
首先看下针对ExecutorService提供的一些工 ...
Jdk1.6 JUC源码解析(19)-ScheduledThreadPoolExecutor
Jdk1.6 JUC源码解析(19)-ScheduledThreadPoolExecutor
作者：大飞
功能简介：
ScheduledThreadPoolExecutor是一种类似Timer的定时器或者说是调度器，和Timer比起来主 ...
Jdk1.6 JUC源码解析(18)-DelayQueue
Jdk1.6 JUC源码解析(18)-DelayQueue
作者：大飞
功能简介：
DelayQueue是一种无界的阻塞队列，队列里只允许放入可以"延期"的元素，队列中列头的元素是最先"到期"的元素。如果队列中没有任何元素"到期"，尽管队列中有元素，也不能从队列头获取到任何元素。
源码分析：
首先还是看一下 ...
Jdk1.6 JUC源码解析(17)-ThreadPoolExecutor
Jdk1.6 JUC源码解析(17)-ThreadPoolExecutor
作者：大飞
功能简介：
ThreadPoolExecutor是JUC包中提供的线程池，使用ThreadPoolExecutor的好处一方面是能重用线程资源，避免重复创建线程带来的开销；另一方面是ThreadPoolExecutor提供了内部资源(线程、任务)的管理功能，方便我们监控线程池工作状态。
...
Jdk1.6 JUC源码解析(16)-FutureTask
Jdk1.6 JUC源码解析(16)-FutureTask
作者：大飞
功能简介：
FutureTask是一种异步任务(或异步计算)，举个栗子，主线程的逻辑中需要使用某个值，但这个值需要复杂的运算得来，那么主线程可以提前建立一个异步任务来计算这个值(在其他的线程中计算)，然后去做其他事情，当需要这个值的时候再通过刚才建立的异步任务来获取这个值，有点并行的意思，这样可以缩短整个主 ...
- 专栏创建者：BrokenDreams
- 创建时间：2015-12-09 12:59:38
- 专栏文章数：35篇
- 专栏被浏览：100146 次
本专栏热门文章
最新评论
acquire方法里面为什么tryAcquire会被调用多次？第一次tryAcquire失败了就表明 ...
有贝无患 评论了 Jdk1.6 JUC源码解析(6)-locks-AbstractQueu ...
有贝无患 评论了 Jdk1.6 JUC源码解析(6)-locks-AbstractQueu ...
library_call.cpp 里面的内联操作 inline_unsafe_ordered_stor ...
zwy_qz 评论了 Jdk1.6 JUC源码解析(1)-atomic-AtomicXXX
zwy_qz 评论了 Jdk1.6 JUC源码解析(1)-atomic-AtomicXXX
您好，正在学习您的文章，中间有一段，一直没明白：“private void setHead(Node ...
sunwang810812 评论了 Jdk1.6 JUC源码解析(6)-locks-AbstractQueu ...
sunwang810812 评论了 Jdk1.6 JUC源码解析(6)-locks-AbstractQueu ...
有个问题不明白，共享模式，释放的时候调用doReleaseShared，for循环里面unparkSu ...
xuyb2 评论了 Jdk1.6 JUC源码解析(6)-locks-AbstractQueu ...
xuyb2 评论了 Jdk1.6 JUC源码解析(6)-locks-AbstractQueu ...
好文章，自己看源码遇到好多不理解的地方。这里都能找到。。。源码分析从例子上出发，才好理解。。。单个类分 ...
在世界的中心呼喚愛 评论了 Jdk1.7 JUC源码增量解析(4)-ForkJoin-ForkJ ...
在世界的中心呼喚愛 评论了 Jdk1.7 JUC源码增量解析(4)-ForkJoin-ForkJ ...