第7章 线程池与AQS
java.util.concurrent包中的绝大多数同步工具,如锁(locks)和屏障(barriers)等,都基于AbstractQueuedSynchronizer(简称AQS)构建而成。这个框架提供了一套同步管理的通用机制,如同步状态的原子性管理、线程阻塞与解除阻塞,还有线程排队等。
在JDK1.5引入了java.util.concurrent包,其中包含多个支持中等级别线程并发的类,如可重入锁(ReentrantLock)、读锁(ReentrantReadWriteLock.ReadLock)、写锁(Reentrant-ReadWriteLock.WriteLock)、信号量(Semaphore)、屏障(CyclicBarrier)、Future对象、事件指示器以及传送队列等。这些同步类主要有如下功能:
(1)对象内部同步状态的维护(如表示锁的状态是已获取还是已释放)。
(2)更新和检查状态的操作。而且至少有一个方法会导致调用线程在同步状态被获取时被阻塞,以及在其他线程改变这个同步状态时解除线程的阻塞。
几乎任何一个知名的同步器都可以用来实现其他形式的同步器。例如,可以用可重入锁(ReentrantLock)来实现信号量(Semaphore);反之,用信号量也可以实现可重入锁。但是,这样做会带来复杂性高、开销过大、不灵活等问题,使其最终只能成为一个二流项目。而使用AQS用户可以用简洁的方式定义自己的线程同步器。