JDK8并发包速览

  这篇文章有助于快速理解JDK8中juc包中的各个并发类。与《java并发编程系统与模型》配合起来看更好。由于时间和精力的关系,这篇文档会一直更新,直到达到让读者满意的标准。

AbstractExecutorService: 抽象的执行器

ArrayBlockingQueue: 一个有边界的先进先出的阻塞队列

BlockingDeque: 接口描述,阻塞双端队列

BlockingQueue: 接口描述,阻塞队列

BrokenBarrierException:当Barrier被破坏的时候,会抛出此异常

Callable: 带返回值的异步任务接口。其值不能直接被获取,而是要通过Future来获取,JDK8中已经被Supplier取代

CancellationException: 如果在执行器框架中,带返回值的任务已经被取消而无法重新取回,将抛出此异常

CompletableFuture: 1.8中新增的类。将执行的结果以回调的方式处理,而不是阻塞等待。被喻作“可完成的Future”

CompletionException: 在计算结果或者任务的过程中抛出的异常

CompletionService: 对应ExecutorService ,ExecutorService每次执行都需要等待返回结果,CompletionService则可集中的等待返回结果。其实现类是ExecutorCompletionService

CompletionStage: 代表异步计算中的一个阶段或步骤。其实现是CompletableFuture

ConcurrentHashMap: 并发的,线程安全的HashMap
改进一:取消segments字段,直接采用transient volatile HashEntry<K,V>[] table保存数据,采用table数组元素作为锁,从而实现了对每一行数据进行加锁,进一步减少并发冲突的概率。

改进二:将原先table数组+单向链表的数据结构,变更为table数组+单向链表+红黑树的结构。对于hash表来说,最核心的能力在于将key hash之后能均匀的分布在数组中。如果hash之后散列的很均匀,那么table数组中的每个队列长度主要为0或者1。但实际情况并非总是如此理想,虽然ConcurrentHashMap类默认的加载因子为0.75,但是在数据量过大或者运气不佳的情况下,还是会存在一些队列长度过长的情况,如果还是采用单向列表方式,那么查询某个节点的时间复杂度为O(n);因此,对于个数超过8(默认值)的列表,jdk1.8中采用了红黑树的结构,那么查询的时间复杂度可以降低到O(logN),可以改进性能。

ConcurrentLinkedDeque: 并发的,线程安全的无界双端队列

ConcurrentLinkedQueue: 并发的,线程安全的无界队列

ConcurrentMap: 接口描述。并发Map通用接口

ConcurrentNavigableMap: 并发的NavigableMap。这种Map可以按照可以按照键的升序或降序访问和遍历

ConcurrentSkipListMap: 一个以跳表(SkipList)作为数据结构的并发Map。Key有序(不是插入顺序,而是Key的自然顺序或者自定义顺序)

注意,JDK中并没有如下两个并发类的实现,但依旧说明:

ConcurrentLinkedHashMap 保证了插入顺序的HashMap

ConcurrentTreeMap按照Key来排序,实现了NavigableMap。说明是按照Key的自然顺序。

ConcurrentSkipListSet: 一个以跳表为实现的按照值自然有序的(或者自定义顺序)并发的Set集合

CopyOnWriteArrayList: CopyOnWrite容器

CopyOnWriteArraySet: CopyOnWrite容器

CountDownLatch: 一个同步工具类,它允许一个或多个线程一直等待,直到其他线程的操作执行完后再执行

CountedCompleter: Java 8添加了一个称为CountedCompleter的ForkJoinTask类的抽象子类。
该框架同时支持两种类型的任务:不产生结果的任务和产生结果的任务。

RecursiveAction:类的实例表示不产生结果的任务。 RecursiveTask类的实例表示产生结果的任务。

CountedCompleter:任务可能产生结果,也可能不产生结果。

CyclicBarrier: :一个同步辅助类,它允许一组线程互相等待,直到到达某个公共屏障点

作用与CountDownLatch类似
Delayed: 延迟队列的协议接口
DelayQueue: 延迟队列
Exchanger: 可以在两个线程之间交换数据,只能是2个线程,他不支持更多的线程之间互换数据。

ExecutionException

Executor: 执行器接口

ExecutorCompletionService: CompletionService的具体实现
Executors: ExecutorService的生产工厂

ExecutorService: 执行器
ForkJoinPool:是一个可以执行ForkJoinTask的ExcuteService

ForkJoinTask: 代表一个需要执行的任务

ForkJoinWorkerThread: ForkJoinPool管理着ForkJoinWorkerThread线程,ForkJoinWorkerThread线程内部有一个双端队列,这个双端队列主要由一个数组queue、数组下标queueBase、数组上标queueTop三个值保证。

Future: 接口 代表着一个异步执行的结果
FutureTask: 一个可取消的异步计算,FutureTask 实现了Future的基本方法,提空 start cancel 操作,可以查询计算是否已经完成

LinkedBlockingDeque: 基于链表的,线程安全的双端队列,可以指定链表容量,也可以不指定(默认Integer.MAX_VALUE)

LinkedBlockingQueue: 基于链表的,线程安全的队列,可以指定链表容量,也可以不指定(默认Integer.MAX_VALUE)

LinkedTransferQueue: TransferQueue的具体实现

Phaser: 包含了CyclicBarrier和CountDownLatch的相关功能。但提供更多更复杂的功能

PriorityBlockingQueue: 支持优先级的阻塞队列

RecursiveAction: ForkJoinTask的实现,没有返回值

RecursiveTask: ForkJoinTask的实现,带返回值

RejectedExecutionException

RejectedExecutionHandler: 实现RejectedExecutionHandler,在执行器中管理被拒绝的任务

RunnableFuture: 接口比较简单,继承了Runnable、Future接口。并只有一个run方法作为 Runnable 的 Future。成功执行 run 方法可以完成 Future 并允许访问其结果。

RunnableScheduledFuture: 可返回结果的周期性执行接口

ScheduledExecutorService: 可周期性地执行任务的执行器的接口
ScheduledFuture: 执行周期性结果的接口
ScheduledThreadPoolExecutor: 可周期性地执行任务的执行器的实现

Semaphore: 信号量

SynchronousQueue:
这样 一种阻塞队列,其中每个 put 必须等待一个 take,反之亦然。同步队列没有任何内部容量,甚至连一个队列的容量都没有。
不能在同步队列上进行 peek

ThreadFactory 创建线程的工厂。比如需要对线程设置编号和名字等

ThreadLocalRandom 多线程模式下的随机数生成器

ThreadPoolExecutor 线程池执行器

TimeoutException 阻塞操作的超市异常

TimeUnit 线程安全的时间转换类

TransferQueue TransferQueue是一个聪明的队列,它是ConcurrentLinkedQueue

SynchronousQueue (在公平模式下), 无界的LinkedBlockingQueues等的超集。生产者会一直阻塞直到所添加到队列的元素被某一个消费者所消费(不仅仅是添加到队列里就完事)。新添加的transfer方法用来实现这种约束。顾名思义,阻塞就是发生在元素从一个线程transfer到另一个线程的过程中,它有效地实现了元素在线程之间的传递

AtomicBoolean 原子操作类
AtomicInteger

AtomicIntegerArray 原子的整形数组操作类

AtomicIntegerFieldUpdater 原子更新引用类型里的字段。
AtomicLong Long类型原子操作
AtomicLongArray Long类型素组原子操作

AtomicLongFieldUpdater 原子更新引用类型的Long字段

AtomicMarkableReference 维护带有标记位的对象引用,可以原子方式对其进行更新

AtomicReference 原子更新对象
AtomicReferenceArray 原子更新对象数组
AtomicReferenceFieldUpdater 原子更新成员变量
AtomicStampedReference 带有时间戳的原子对象引用

累加器:

DoubleAccumulator

DoubleAdder
LongAccumulator

LongAdder
Striped64

包 java.util.concurrent.locks

AbstractOwnableSynchronizer 抽象同步器

AbstractQueuedLongSynchronizer 64位版本的抽象同步器。与AbstractQueuedSynchronizer除了 state不一样,全都一样

AbstractQueuedSynchronizer 抽象同步器 继承自AbstractOwnableSynchronizer

Condition 条件

Lock 通用的锁接口

LockSupport 底层的线程操作

ReadWriteLock 读写锁的统一接口

ReentrantLock 可重入锁

ReentrantReadWriteLock 可重入的读写锁

StampedLock JAVA8 新增 StampedLock要比ReentrantReadWriteLock更加廉价,也就是消耗比较小。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,948评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,371评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,490评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,521评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,627评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,842评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,997评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,741评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,203评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,534评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,673评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,339评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,955评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,770评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,000评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,394评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,562评论 2 349

推荐阅读更多精彩内容

  • 一、并发 进程:每个进程都拥有自己的一套变量 线程:线程之间共享数据 1.线程 Java中为多线程任务提供了很多的...
    SeanMa阅读 2,419评论 0 11
  • layout: posttitle: 《Java并发编程的艺术》笔记categories: Javaexcerpt...
    xiaogmail阅读 5,804评论 1 19
  • 一.线程安全性 线程安全是建立在对于对象状态访问操作进行管理,特别是对共享的与可变的状态的访问 解释下上面的话: ...
    黄大大吃不胖阅读 834评论 0 3
  • 译序 本指南根据 Jakob Jenkov 最新博客翻译,请随时关注博客更新:http://tutorials.j...
    高广超阅读 5,091评论 1 68
  • JS调试:只能在页面上。 其它代码调试:必须先设断点,再按启动键,再对页面进行相应事件触发。
    余生筑阅读 190评论 0 0