Java中的基础构建模块（第五章）

Java中的基础构建模块

Java平台类库包含了丰富的并发基础构建模块，例如线程安全的容器类以及各类用于协调多个相互协做的线程控制流的同步工具类。

1.同步容器类

同步容器类都是线程安全的，但在某些状况下可能须要额外的客户端加锁来保护复合操做。常见的复合操做包括：迭代、跳转（在容器内元素之间）、条件运算（例如“若没有则添加”）。

隐式迭代：某些状况下迭代操做会隐藏起来。以下代码中println调用Set的toString方法，而后对Set中的对象进行迭代调用toString方法：

public class HiddenIterator {
	private final Set<Integer> set = new HashSet<Integer>();
    public void addTenThings() {
    	Random r = new Random();
        for (int i = 0;i < 10;i++) add(r.nextInt());
        System.out.println("Debug : " + set);
    }
}

2.并发容器类

并发容器专门针对多个线程并发访问设计。 经过使用并发容器代替同步容器，能够极大提升伸缩性并下降风险。

1. ConcurrentHashMap：替代同步的基于散列Map，在其接口中增长了一些常见符合操做的支持，如“若没有则添加”、替换、有条件删除等。 ConcurrentHashMap使用了一种粒度更细的加锁机制：分段锁来实现更大程度的共享，可以在并发环境下提升吞吐量。 ConcurrentHashMap不能被加锁来执行独占访问。 在实际使用中，只有当应用程序须要加锁以进行独占访问时，才应该放弃使用ConcurrentHashMap。

ConcurrentHashMap中的原子操做：

方法	说明
v putIfAbsent(K key,V value)	仅当k没有相应的映射值时才插入
boolean remove(K key,V value)	仅当k被映射到v时才移除
boolean replace(K key,V oldValue,V newValue)	仅当k被映射到oldValue时才进行替换
V replace(K key,V newValue)	仅当k被映射到某个值时才进行替换

2. CopyOnWriteArrayLIst：代替同步List，提供了更好的并发性能，而且在迭代期间不须要对容器进行加锁或复制。 “写入时复制（Copy-On-Write）”容器的线程安全性在于，只要正确地发布一个事实不可变对象，那么在访问该对象时就不须要进一步的控制，在每次修改时，都会建立并发布一个新的容器副本，从而实现可变性。 仅当迭代操做远远多于修改操做时，才应该使用“写入时复制”容器。

3. BlockingQueue（生产者----消费者）：相对于Queue，增长了可阻塞的插入和获取等操做。若是队列为空，那么获取元素的操做将一直阻塞，直到队列中出现一个可用的元素，若是队列已满（对于有界队列），那么插入操做将会一直阻塞，直到队列中出现可用空间。 阻塞队列提供了可阻塞的take和put方法，以及支持定时的offer和poll方法。 在构建高可靠的应用程序时，有界队列是一种强大的资源管理工具：它们能抑制并产生过多的工做项，使应用程序在负荷过载的状况下变得更加健壮。因此应该经过阻塞队列在设计中构建资源管理机制。

   • LinkedBlockingQueue
   • ArrayBlockingQueue
   • PriorityBlockingQueue

串行线程封闭：线程封闭对象只能由一个线程拥有，但能够经过安全地发布该对象来“转移”全部权，在转移全部权后，也只有另外一个线程能得到这个对象的访问权限，而且发布对象的线程不会再访问它。

4. 双端队列 Deque---->BlockingDeque---->ArrayBlockingQueue、LinkedBlockingQueue

3.阻塞与中断

线程阻塞的缘由： - 等待I/O操做结束 - 等待得到一个锁 - 等待从sleep方法醒来 - 等待另外一个线程的计算结果

Thread.interrupt()用于中断线程。Thread.interrupt（）方法不会中断一个正在运行的线程。这一方法实际上完成的是，在线程受到阻塞时抛出一个中断信号，这样线程就得以退出阻塞的状态。更确切的说，若是线程被Object.wait， Thread.join和 Thread.sleep三种方法之一阻塞，那么，它将接收到一个中断异常（InterruptedException），从而提前地终结被阻塞状态。

所以，若是线程被上述几种方法阻塞，正确的中止线程方式是设置共享变量，并调用interrupt（）（注意变量应该先设置）。若是线程没有被阻塞，这时调用interrupt（）将不起做用；不然，线程就将获得异常（该线程必须事先预备好处理此情况），接着逃离阻塞状态。在任何一种状况中，最后线程都将检查共享变量而后再中止。

4.同步工具类

同步工具类能够是任何一个对象，只要它根据其自身的状态来协调线程的控制流。阻塞队列能够做为同步工具类，其余类型的同步工具类还包括信号量（Semaphore）、栅栏（Barrier）以及闭锁（Latch）。

• 闭锁（Latch）：闭锁是一种同步工具类，能够延迟线程的进度直到其到达终止状态。闭锁的做用至关于一扇门：在闭锁到达结束状态以前，这扇门一直是关闭的，而且没有任何线程可以经过，当到达结束状态时，这扇门会打开并容许全部的线程经过。当闭锁到达结束状态后，将不会再改变状态，所以这扇门将永远保持打开状态。 闭锁能够用来确保某些活动直到其余活动都完成后才继续执行，如：
  1. 确保某个计算在其须要的全部资源都被初始化以后才继续执行
  2. 确保某个服务在其依赖的全部其余服务都已经启动以后才启动
  3. 等待直到某个操做的全部参与者（如在多玩家游戏中的全部玩家）都就绪再继续执行。

Java提供了闭锁的实现：CountDownLatch。它可使一个或多个线程等待一组时间发生。闭锁状态包括一个计数器，该计数器被初始化为一个正数，表示须要等待的事件数量。countDown()方法递减计数器，表示有一个时间已经发生了；await()方法等待计数器到达0，表示全部须要等待的事件都已经发生，若是计数器非0，await会一直阻塞直到计数器为0，或等待中的线程中断、超时。

• FutureTask FutureTask实现了Future语义，表示一种抽象的可生成结果的计算。Future.get的行为取决于任务的状态，若是任务已经完成，那么get会当即返回结果，不然get将阻塞直到任务进入完成状态，而后返回结果或者抛出异常。 FutureTask表示的计算是经过Callable来实现的，至关于一种可生成结果的Runnable，而且能够处于如下3种状态：等待运行（Waiting to run)、正在运行（Running）和运行完成（Completed）。 关于FutureTask的详细信息能够参看blog： Java中建立线程的方法

• 信号量 计数信号量（Counting Semaphore）用来控制同时访问某个特定资源的操做数量，或者同时执行某个指定操做的数量，计数信号量还能够用来实现某种资源池，或者对容器施加边界。

• 栅栏 栅栏相似于闭锁，它能则色一组线程直到某个事件发生。栅栏与闭锁的关键区别在于：全部线程必须同时到达栅栏位置，才能继续执行。闭锁用于等待事件，而栅栏用于等待其余线程。若是全部线程都达到了栅栏位置，那么栅栏将打开，此时全部的线程都被释放，而栅栏将被重置以便下次使用。 Java中提供CyclicBarrier实现栅栏功能。