J.U.C源码阅读笔记（零）java.util.concurrent

| |

java.util.concurrent是自JDK1.5提供的一个并发工具包。

J.U.C 框架包含的内容有(以下内容转自这里!!!)：

  • Executor 框架（线程池、Callable、Future），任务的执行和调度框架；
  • AbstractQueuedSynchronizer（AQS框架），J.U.C 中实现锁和同步机制的基础；
  • Locks & Condition（锁和条件变量），比 synchronized、wait、notify 更细粒度的锁机制；
  • Synchronizers（同步器），主要用于协助线程同步，有 CountDownLatch、CyclicBarrier、Semaphore、Exchanger；
  • Atomic Variables（原子变量），方便程序员在多线程环境下，无锁的进行原子操作，核心操作是 CAS 原子操作，所谓的 CAS 操作，即 compare and swap，指的是将预期值与当前变量的值比较(compare)，如果相等则使用新值替换(swap)当前变量，否则不作操作；
  • BlockingQueue（阻塞队列），阻塞队列提供了可阻塞的入队和出对操作，如果队列满了，入队操作将阻塞直到有空间可用，如果队列空了，出队操作将阻塞直到有元素可用；
  • Concurrent Collections（并发容器），说到并发容器，不得不提同步容器，在 JDK1.5 之前，为了线程安全，我们一般都是使用同步容器，同步容器主要的缺点是：对所有容器状态的访问都串行化，严重降低了并发性；某些复合操作，仍然需要加锁来保护；迭代期间，若其它线程并发修改该容器，会抛出 ConcurrentModificationException 异常，即快速失败机制；
  • Fork/Join 并行计算框架，这块内容是在 JDK1.7 中引入的，可以方便利用多核平台的计算能力，简化并行程序的编写，开发人员仅需关注如何划分任务和组合中间结果；框架的核心是 ForkJoinPool 类，实现了工作窃取算法（对那些处理完自身任务的线程，会从其它线程窃取任务执行）并且能够执行 ForkJoinTask 任务；
  • TimeUnit 枚举，TimeUnit 是 java.util.concurrent 包下面的一个枚举类，TimeUnit 提供了可读性更好的线程暂停操作，以及方便的时间单位转换方法；

整个架构如下(下图转自这里!!!)：

JUCFramework

参考

Related Posts