委托是创建线程安全类的一个最有效的策略:只需让现有的线程安全类管理所有的状态即可。在本篇博文中,主要介绍一些比较有用的并发构建模块,特别是在 Java 5.0 和 Java 6.0 中引入的一些新模块,以及在使用这些模块来构造应用程序时的一些常用模式。
最早出现的同步容器类是Vector
和Hashtable
,在 JDK 1.2 及之后,又提供了一些功能类似的封装器类,这些同步容器类是由Collections.synchronizedXxx
等工厂方法创建的,其实现线程安全的方式是:将它们的状态封装起来,并对每个公有方法都进行同步,使得每次只有一个线程能访问容器的状态。
同步容器类都是线程安全的,但在某些情况下可能需要额外的客户端加锁来保护符合操作。容器上常见的复合操作包括:迭代、跳转以及条件运算。在同步容器类中,这些复合操作在没有客户端加锁的情况下是线程安全的,但是在其他线程并发的修改容器时,它们可能会表现出意料之外的行为。
for (int i = 0; i < vector.size(); i++) {
doSometing(vector.get(i));
}
如上述代码所示,在调用size()
和相应get()
方法之之间,Vector
的长度可能会发生变化,这种风险在对Vector
中的元素进行迭代时就可能出现。因此,上述的代码可能在运行时抛出ArrayIndexOutOfBoundsException
异常。解决这种风险的方式就是在客户端先对其进行加锁,然后在进行迭代操作,例如:
synchronized(vector) {
for (int i = 0; i < vector.size(); i++) {
doSometing(vector.get(i));
}
}
对于这种复合操作存在并发风险的问题,不仅出现在Vector
之中,在 JDK 5.0 引入的for-each
循环语法中也存在类似的问题。虽然加锁可以防止迭代器抛出ConcurrentModificationException
,但是我们必须记住在所有对共享容器进行迭代的地方都需要加锁。实际情况要更加复杂,因为在某些情况下,迭代器会隐藏起来,例如:
public class HiddenIterate {
private final Set<Integer> set = new HashSet<Integer>();
public synchronized void add(Integer i) {
set.add(i);
}
public synchronized void remove(Integer i) {
set.remove(i);
}
public void addTenThings() {
Random random = new Random();
for (int i = 0; i < 10; i++) {
add(random.nextInt());
}
System.out.println("DEBUG: added ten elements to " + set);
}
}
在上述代码中,addTenThings()
方法可能会抛出ConcurrentModificationException
异常,因为在生成调试信息的过程中,toString()
方法会对容器进行迭代。在使用println
中的set
之前必须首先获取HiddenIterate
的锁,但是在调试代码和日志代码中通常会忽视这个要求。容器的hashCode()
和equal()
等方法也会间接地执行迭代操作,当容器作为另一个容器的元素或键值时,就会出现这种情况。通常,containsAll()
、removeAll()
和retainAll()
等方法,以及把容器作为参数的构造函数,都会对容器进行迭代。