java:基于volatile和Thread Local Storage的双重检查锁定实现延迟初始化
java:基于volatile和Thread Local Storage的双重检查锁定实现延迟初始化
总在同一个地方栽坑里是不可原谅的,以本文做个记录，以防下次再犯。 下面这段很简单的基于双重检查锁定(Double-checked locking)实现的延迟初始化(Lazy initialization)代码,还是让spotbugs找出了问题(感谢spotbugs)。 原因很简单,这种模式在java下无效，因为filedNames 变量不是线程可见的，具体原因涉及到java内存模型,网上已经有文章很深入的介绍，参见本文末尾的参考资料4
private List<String> filedNames = null;
public List<String> getFieldNames() {
// Double-checked locking
if(null == filedNames){
synchronized(this){
if(null == filedNames){
filedNames = doGetFieldNames();
}
}
}
return filedNames;
}解决方案1
把 fieldName 声明为volatile型,其他代码不变。 注意： 这个解决方案需要JDK5或更高版本（因为从JDK5开始使用新的JSR-133内存模型规范，这个规范增强了volatile的语义）。关于volatile关键字的含义参见参考资料。
/** JDK5 required */
private volatile List<String> filedNames = null;
public List<String> getFieldNames() {
// Double-checked locking
if(null == filedNames){
synchronized(this){
if(null == filedNames){
filedNames = doGetFieldNames();
}
}
}
return filedNames;
}解决方案2
基于线程本地存储TLS(Thread Local Storage)实现双重检查锁定,这个方法也是 《The “Double-Checked Locking is Broken” Declaration》论文中提出的方案之一。 这个方案不需要volatile关键字支持当然也就没有JDK5以上版本的要求，但是略复杂,多了一个ThreadLocal变量,并且分成了两个方法。
private volatile List<String> filedNames = null;
/** 如果perThreadInstance.get() 返回一个非null值,说明 filedNames 已经被初始化过了 */
@SuppressWarnings("rawtypes")
private final ThreadLocal perThreadInstance = new ThreadLocal();
public List<String> getFieldNames() {
this.assertJavaBean();
if(null == perThreadInstance.get()){
initFieldNames();
}
return filedNames;
}
/** 同步初始化filedNames变量 */
@SuppressWarnings({ "unchecked" })
private void initFieldNames() {
synchronized(this){
if(null == filedNames){
filedNames = doGetFieldNames();
}
}
// 给perThreadInstance设置一个非null值
perThreadInstance.set(perThreadInstance);
}通用化封装
说话仅仅一个延迟初始化就整出这么多问题，搞出这么多代码，虽然问题解决了，但对于我这个懒人来说实在太复杂了，如果项目中还有多个地方要用到延迟初始化，每个都要这么写代码实在是一件非常痛苦的事儿。 既然原理搞明白了，那么把这两种延迟初始化的解决方案用用泛型类封装一下不就可以复用了么？
于是我很快把上面的代码做了封装，顶层是接口类ILazyInitVariable，只有一个接口方法get(),接下来是个中间BaseLazyVar抽象类定义一个doGet()方法用于具体的初始化，BaseTls和BaseVolatile分别是基于前述方案2和方案1的具体实现类(也是抽象类,具体doGet()方法还是需要子类来完成)
完整代码如下
ILazyInitVariable.java
接口定义 ILazyInitVariable.java，中间抽象类BaseLazyVar也在其中
package gu.simplemq;
/**
* 延迟初始化(Lazy initialization)变量封装接口
* @author guyadong
*
* @param <T> 延迟变量类型
*/
public interface ILazyInitVariable<T> {
public static abstract class BaseLazyVar<T> implements ILazyInitVariable<T>{
/**
* 返回 T 实例
* @return
*/
abstract protected T doGet() ;
}
/**
* 返回延迟初始化的 T 实例
* @return
*/
public T get();
}BaseVolatile.java
package gu.simplemq;
/**
* 基于volatile的双重检查锁定实现{@link ILazyInitVariable}的抽象类<br>
* 要求 JDK5 以上版本
* @author guyadong
*
* @param <T> variable type
*/
public abstract class BaseVolatile<T> extends ILazyInitVariable.BaseLazyVar<T>{
private volatile T var = null;
public BaseVolatile() {
}
@Override
public T get() {
// Double-checked locking
if(null == var){
synchronized(this){
if(null == var){
var = doGet();
}
}
}
return var;
}
}BaseTls.java
package gu.simplemq;
/**
* 基于Thread Local Storage的双重检查锁定实现{@link ILazyInitVariable}的抽象类<br>
* @author guyadong
*
* @param <T> variable type
*/
public abstract class BaseTls<T> extends ILazyInitVariable.BaseLazyVar<T> {
/**
* If perThreadInstance.get() returns a non-null value, this thread has done
* synchronization needed to see initialization of helper
*/
@SuppressWarnings("rawtypes")
private final ThreadLocal perThreadInstance = new ThreadLocal();
private T var = null;
public BaseTls() {
}
@Override
public T get() {
if (null == perThreadInstance.get()) {
initFieldNames();
}
return var;
}
@SuppressWarnings({ "unchecked" })
private void initFieldNames() {
synchronized (this) {
if (null == var) {
var = doGet();
}
}
// Any non-null value would do as the argument here
perThreadInstance.set(perThreadInstance);
}
}使用示例
有了通用化封装，以用BaseVolatile为例
本文最开始的延迟初始化代码就很简单了：
// filedNames 定义为ILazyInitVariable接口实例，并用BaseVolatile类实例化
private final ILazyInitVariable<List<String>>filedNames = new BaseVolatile<List<String>>(){
@Override
protected List<String> doGet() {
// 调用初始化方法
return doGetFieldNames();
}};
public List<String> getFieldNames() {
return filedNames.get();
}