Java学习总结(1.3.4) 并发工具类详解

并发工具类

J.U.C并发编程包详解

Semaphore

Semaphore是一个计数信号量,常用于限制可以访问某些资源(物理或逻辑的)线程数目。

简单说,是一种用来控制并发量的共享锁

信号量的本质,共享锁,这个共享锁有上限

CountDownLatch

当所有线程执行完成后,我才能执行。

例1：火箭发射

例2：运动员起跑

CyclicBarrier

设置一定数量，只有当满了，才能一起执行下去。

FutureTask

是一个一次性的任务，会有生命周期，只能被一个线程执行。

多个线程都想执行这个任务,需要抢在务,抢到了才能执行

CAS

ForkJoin

关键点:分解任务fork出新任务,汇集join任务执行结果

并发处理框架：

MR/Spark/Flink