职业IT人-IT人生活圈

 找回密码
 成为会员
搜索
查看: 901|回复: 9

关于单例模式的DoubleCheckLock同步的思考

[复制链接]
yoyo 发表于 2011-8-31 10:18 | 显示全部楼层 |阅读模式
在javaeye上看到很多朋友都提出单例模式的一些变种实现,比如加入了即时加载和DoubleCheckLock机制,来提高并发性能。但事实上这些机制真的必要吗?

目前公认影响单例性能的要素有两个:一是实例构造时间开销,一是获取单例实例的同步阻塞开销。

我的理解是,并发相对与同步阻塞的优势,在于当两条线程中的一条在执行时间开销较大的操作,而另一条线程无须执行该操作,则并发执行保证了开销小的线程不需等待开销大的,能正常执行完毕。然而,如果所有线程都只执行一些基本的操作,例如“返回结果”,“变量赋值”,“判断跳转”等,是否并发执行对性能并没有实质性的提升。差别只在于到底在jdk层面在同步块上排队,还是在cpu层面在时间片分配上排队。

对于一个基本的单例模式,在每个jvm中肯定只会发生一次单例构造。同步机制虽然保护的是构造过程,但99%时间锁的是返回结果过程。而对于这种基本操作,有锁和无锁差别真的是这么大(据说有100倍的差别)吗?

网上常见的单例实现有以下几种:

1. 延迟加载的基本实现
  
public class Singleton {      
  
    private static Singleton instance = null;      
  
    public static synchronized Singleton getInstance() {   
        if (instance == null) {   
            instance = new Singleton();   
        }   
        return instance;   
    }   
}  

public class Singleton {   

    private static Singleton instance = null;   

    public static synchronized Singleton getInstance() {
        if (instance == null) {
            instance = new Singleton();
        }
        return instance;
    }
}
2. 即时加载的基本实现
  
public class Singleton {      
  
    private static Singleton instance = new Singleton();      
  
    public static Singleton getInstance() {   
        return instance;   
    }   
}  

public class Singleton {   

    private static Singleton instance = new Singleton();   

    public static Singleton getInstance() {
        return instance;
    }
}
3. DoubleCheck同步延迟加载
  
public class Singleton {      
  
    private static Singleton instance = null;      
  
    public static Singleton getInstance() {   
        if (instance == null) {   
            synchronized (Singleton.class) {   
                if (instance == null) {   
                    instance = new Singleton();   
                }   
            }   
        }   
        return instance;   
    }   
}  

public class Singleton {   

    private static Singleton instance = null;   

    public static Singleton getInstance() {
        if (instance == null) {
            synchronized (Singleton.class) {
                if (instance == null) {
                    instance = new Singleton();
                }
            }
        }
        return instance;
    }
}

举个极端的量化例子,假如有一个单例对象被500条线程使用。单例的构造器中由于使用了一些耗时的资源,执行一次约为1s。但如果单例实例已经创建好,在getInstance()中直接return该实例,耗时为0.1ms。这500条线程中的其中200条会每隔10分钟(以机器内时钟为准)同时访问这个单例对象。

另外,先假定并发操作对于一些基本的操作,例如方法返回,赋值,判断跳转等不会带来性能上的大幅提升(这与JDK的实现有关)。换句话说,200条线程中“返回实例”动作,无论是否在同步块中,总耗时都是0.1*200=20ms。

那么,

第一种情况:首次访问时,第一条线程锁住getInstance(),并执行1s的实际构造逻辑并返回实例(耗时1.0001秒),其他199条线程依次排队。在单例构造好后再依次获取实例,最慢一条线程耗时1.02秒。 二次访问时,所有线程都依次排队获取实例,最慢一条线程耗时0.02秒

第二种情况:在类装载时,构造单例实例耗时1s。首次访问时,200条线程并发获取实例,由于在cpu上还是要排队,最慢一条线程耗时0.02秒。(也就是说,从系统启动到首次访问完成,耗时1.02秒)。二次访问时,所有线程都并发获取实例,最慢一条线程耗时0.02秒。

第三种情况:首次访问时,与第一种情况类似(因为所有线程都通过了instance == null,在同步块上排队),最慢线程耗时1.02秒。二次访问时,所有线程都并发获取实例,但由于增加了条件判断(假设判断跳转时间为1ms),最慢一条线程耗时约为0.04秒。

可以看出,如果假定并发对基本操作时间无影响时,综合性能第一种和第二种一致,第三种最低,但差别均在微秒级别,事实上可以忽略。

需要注意的是,对于一个单例来说,上面例子中的线程总数500是个多余量,对结果完全没有影响。换句话说,是否延迟加载对于单个单例的性能没有影响。

如果假定jdk的实现使得基本操作在并发环境下性能较高,假设返回结果与条件判断的平均性能在并发下能提高1倍(双核?),变成0.05ms。那么,
第一种情况(完全没有利用并发):首次访问最慢线程:1.02秒,二次访问最慢线程0.02秒。
第二种情况:类载入时:1秒,首次访问最慢线程0.01秒(系统启动到完成首次访问总耗时1.01秒),二次访问最慢线程0.01秒
第三种情况:首次访问最慢线程1.01秒,二次访问最慢线程0.02秒。

同样可以看出,三种情况即使有差别,但差别均在微秒级别,事实上可以忽略。而且如果要较真的话,第三种情况还可能会慢,关键在于并发环境下返回结果的性能提升能否抵消多出来的两次判断跳转。

上面讨论的是一个单例被多条线程同时使用的情况。延时读取是考虑的是系统中存在大量不同单例的某些特殊情况。例如即时加载的劣势,体现在如果系统中有50个不同的单例类,而在某条执行路线上只载入了其中2个,即时加载会导致其他48个单例实例被无谓地创建。问题是在系统中定义了大量的单例类(要注意单例是难以继承的),而主线逻辑中又只使用了其中少量的现实场景究竟有多少。

综上,个人感觉在一般场景中,基本延迟加载方案与基本即时加载方案的效果是差不多的,完全可以根据个人喜好选择。除非已知系统中会出现“单例类爆炸”,而主流程又只使用其中少量的情况,那么就需要在团队中强制推行延迟加载方案。DoubleCheck同步加载方案需要证明“返回结果这种基本操作在并发环境下能带来实质的性能提升,足以抵消额外的条件判断的性能损耗”的前提下,才值得推广。

希望进行过实测的朋友来谈谈经验。

==============================

继续想了一下,似乎在这里使用DoubleCheck方式的主要出发点是”避免同步锁自身的初始化开销”,而不是”避免被锁住内容的执行开销“。那么问题就变为”同步锁自身的初始化开销,是否足以抵消额外的条件判断的性能损耗“。看来还是要实测一下。

紫衿 发表于 2011-8-31 10:18 | 显示全部楼层
lz你的第一第二是看应用场景的,区别不仅仅是性能开销上的,二是实例的产生时机上,因为真正需要同步的就是产生实例那个时候的一次而已,但是这样同步是每次取都需要的,也就是同步的开支上不是很科学,第三种你的代码是有问题的,为什么叫双锁呢?很简单,同步了(锁)2次而已,其实我最常用的是用静态内部类来实现单例

郁闷小男人 发表于 2011-8-31 10:18 | 显示全部楼层
如果构造Object的时间你都计较的话,C++也会表示压力巨大。

Java构造对象时,和C++构造没有区别。

时间上,非常快!

特别指出一点,

真正的Double Check Lock是利用volatile 和synchronized配合的,你的代码有问题的。


ClassLoader来做看是比较好,实际上没有比synchronized快多少,因为临界区很小的!

找不到我 发表于 2011-8-31 10:18 | 显示全部楼层
kinjo 写道
lz你的第一第二是看应用场景的,区别不仅仅是性能开销上的,二是实例的产生时机上,因为真正需要同步的就是产生实例那个时候的一次而已,但是这样同步是每次取都需要的,也就是同步的开支上不是很科学,第三种你的代码是有问题的,为什么叫双锁呢?很简单,同步了(锁)2次而已,其实我最常用的是用静态内部类来实现单例


延迟加载和即时加载在实例的产生时机上肯定是不同的。确实有很多明确需要延迟载入的场景,例如单例的构造函数逻辑依赖了外部的上下文,而你又很确定首次使用该单例时外部上下文是符合期待的。例如在web开发里就经常需要使用延迟载入,并传入request对象来获取request scope内的单例。考虑业务需求的话,只需要知道一种即时,一种延时的实现方案就行了。

极端点的话,感觉第一种延时方案基本上可以应付所有的场景了,事实上很少有必须使用即时载入的场景,因为在编写单例的时候,难以确定类是什么时候被载入的,在即时载入的单例构造器中加入依赖外部上下文的逻辑是不太合理的。暂时没想到出于应用场景的考虑必须使用即时载入的情况,有知道的朋友请提醒一下。:)

我思考的出发点在于,目前大部分关于单例的探讨,都是从性能开销上展开的。但如果撇开业务需求不谈,仅仅从性能上看,真的有那么大差别吗?为了一些根本没可能成为性能瓶颈的”性能问题“,记住好几种单例实现的变种和适用场景是否值得。

第三种实现我是随便找了一个帖子复制过来的,因为我平时只用第一种。。。


fossil 发表于 2011-8-31 10:18 | 显示全部楼层
mercyblitz 写道
如果构造Object的时间你都计较的话,C++也会表示压力巨大。

Java构造对象时,和C++构造没有区别。

时间上,非常快!



我指的是构造器里的逻辑,也就是同步锁事实上要保护的那一次执行。

第三种实现我是随便找了一个帖子复制过来的,因为我平时只用第一种。。。

能文能武 发表于 2011-8-31 10:19 | 显示全部楼层
http://www.cs.umd.edu/~pugh/java/memoryModel/DoubleCheckedLocking.html

楠楠 发表于 2011-8-31 10:19 | 显示全部楼层
推荐用第二种饿汉模式,加载的时候即初始化

忘了双重检查同步锁模式!



    在很多介绍java设计模式的书中都介绍到了单例模式,并且介绍过一种双重检查手段,用于提高效率。但是由于java内存模型原因,双重检测在并不能完全成功,在IBM发布的一篇文章具体介绍过失败的原因:http://www.ibm.com/developerworks/cn/java/j-dcl.html

最佳单例模式
       鉴于双重检查失败的原因,可以对单例模式中线程安全和延迟初始化进行改良,用一个内部类来解决问题,以下是源码:

public class Singleton
{
    private Singleton()
    {
    }

    /**
     * 双重检查会出现问题,故使用此种方法来处理线程安全 只有当使用的时候,类才会被初始化。
     *
     */
    private static class SingletonInn
    {
        static Singleton instance = new Singleton();
    }

    public static Singleton getInstance()
    {
        return SingletonInn.instance;
    }

}




shmilyyu 发表于 2011-8-31 10:19 | 显示全部楼层
  
public class ConcurrentSingleton {      
    private static final ConcurrentMap<String, ConcurrentSingleton> map = new ConcurrentHashMap<String, ConcurrentSingleton>();      
    private static ConcurrentSingleton instance;      
     
    public static ConcurrentSingleton getInstance() {      
        if (instance == null) {      
            instance = map.putIfAbsent("INSTANCE", new ConcurrentSingleton());      
        }      
        return instance;      
    }      
}      
  
  
public class AtomicBooleanSingleton {      
    private static AtomicBoolean initialized = new AtomicBoolean(false);      
    private static AtomicBooleanSingleton instance;      
         
    public static AtomicBooleanSingleton getInstantce() {         
        checkInitialized();      
        return instance;         
    }      
         
    private static void checkInitialized() {      
        if(instance == null && initialized.compareAndSet(false, true)) {      
            instance = new AtomicBooleanSingleton();      
        }      
    }      
}     

public class ConcurrentSingleton {   
    private static final ConcurrentMap<String, ConcurrentSingleton> map = new ConcurrentHashMap<String, ConcurrentSingleton>();   
    private static ConcurrentSingleton instance;   
  
    public static ConcurrentSingleton getInstance() {   
        if (instance == null) {   
            instance = map.putIfAbsent("INSTANCE", new ConcurrentSingleton());   
        }   
        return instance;   
    }   
}   


public class AtomicBooleanSingleton {   
    private static AtomicBoolean initialized = new AtomicBoolean(false);   
    private static AtomicBooleanSingleton instance;   
      
    public static AtomicBooleanSingleton getInstantce() {      
        checkInitialized();   
        return instance;      
    }   
      
    private static void checkInitialized() {   
        if(instance == null && initialized.compareAndSet(false, true)) {   
            instance = new AtomicBooleanSingleton();   
        }   
    }   
}   


fossil 发表于 2011-8-31 10:19 | 显示全部楼层
melin 写道
  
public class ConcurrentSingleton {      
    private static final ConcurrentMap<String, ConcurrentSingleton> map = new ConcurrentHashMap<String, ConcurrentSingleton>();      
    private static ConcurrentSingleton instance;      
     
    public static ConcurrentSingleton getInstance() {      
        if (instance == null) {      
            instance = map.putIfAbsent("INSTANCE", new ConcurrentSingleton());      
        }      
        return instance;      
    }      
}      
  
  
public class AtomicBooleanSingleton {      
    private static AtomicBoolean initialized = new AtomicBoolean(false);      
    private static AtomicBooleanSingleton instance;      
         
    public static AtomicBooleanSingleton getInstantce() {         
        checkInitialized();      
        return instance;         
    }      
         
    private static void checkInitialized() {      
        if(instance == null && initialized.compareAndSet(false, true)) {      
            instance = new AtomicBooleanSingleton();      
        }      
    }      
}     

public class ConcurrentSingleton {   
    private static final ConcurrentMap<String, ConcurrentSingleton> map = new ConcurrentHashMap<String, ConcurrentSingleton>();   
    private static ConcurrentSingleton instance;   
  
    public static ConcurrentSingleton getInstance() {   
        if (instance == null) {   
            instance = map.putIfAbsent("INSTANCE", new ConcurrentSingleton());   
        }   
        return instance;   
    }   
}   


public class AtomicBooleanSingleton {   
    private static AtomicBoolean initialized = new AtomicBoolean(false);   
    private static AtomicBooleanSingleton instance;   
      
    public static AtomicBooleanSingleton getInstantce() {      
        checkInitialized();   
        return instance;      
    }   
      
    private static void checkInitialized() {   
        if(instance == null && initialized.compareAndSet(false, true)) {   
            instance = new AtomicBooleanSingleton();   
        }   
    }   
}   



Keep simple,

这样地性能更不好,还不如直接AtomicX类来做,不过还是用地volatile做的!并且还有问题,    private static AtomicBooleanSingleton instance;   这里建议加一个volatile修饰一下!多个线程在观察这个变量地时候,没有volatile结果可能null和非null。

 楼主| yoyo 发表于 2011-8-31 10:19 | 显示全部楼层
mercyblitz 写道
melin 写道
  
public class ConcurrentSingleton {      
    private static final ConcurrentMap<String, ConcurrentSingleton> map = new ConcurrentHashMap<String, ConcurrentSingleton>();      
    private static ConcurrentSingleton instance;      
     
    public static ConcurrentSingleton getInstance() {      
        if (instance == null) {      
            instance = map.putIfAbsent("INSTANCE", new ConcurrentSingleton());      
        }      
        return instance;      
    }      
}      
  
  
public class AtomicBooleanSingleton {      
    private static AtomicBoolean initialized = new AtomicBoolean(false);      
    private static AtomicBooleanSingleton instance;      
         
    public static AtomicBooleanSingleton getInstantce() {         
        checkInitialized();      
        return instance;         
    }      
         
    private static void checkInitialized() {      
        if(instance == null && initialized.compareAndSet(false, true)) {      
            instance = new AtomicBooleanSingleton();      
        }      
    }      
}     

public class ConcurrentSingleton {   
    private static final ConcurrentMap<String, ConcurrentSingleton> map = new ConcurrentHashMap<String, ConcurrentSingleton>();   
    private static ConcurrentSingleton instance;   
  
    public static ConcurrentSingleton getInstance() {   
        if (instance == null) {   
            instance = map.putIfAbsent("INSTANCE", new ConcurrentSingleton());   
        }   
        return instance;   
    }   
}   


public class AtomicBooleanSingleton {   
    private static AtomicBoolean initialized = new AtomicBoolean(false);   
    private static AtomicBooleanSingleton instance;   
      
    public static AtomicBooleanSingleton getInstantce() {      
        checkInitialized();   
        return instance;      
    }   
      
    private static void checkInitialized() {   
        if(instance == null && initialized.compareAndSet(false, true)) {   
            instance = new AtomicBooleanSingleton();   
        }   
    }   
}   



Keep simple,

这样地性能更不好,还不如直接AtomicX类来做,不过还是用地volatile做的!并且还有问题,    private static AtomicBooleanSingleton instance;   这里建议加一个volatile修饰一下!多个线程在观察这个变量地时候,没有volatile结果可能null和非null。


第一个,其实和直接new ConcurrentSingleton()是一样的,这个对象在放进map之前就被构造好了,所以可能会被重复构造多次,这和进不进map已经没有关系了,就算不进,大不了被GC;而且这样实现还可能导致不完全构造的问题。
第二个,有可能会产生空指针异常,同时也存在潜在的不完全构造问题
您需要登录后才可以回帖 登录 | 成为会员

本版积分规则

QQ|手机版|小黑屋|网站帮助|职业IT人-IT人生活圈 ( 粤ICP备12053935号-1 )|网站地图
本站文章版权归原发布者及原出处所有。内容为作者个人观点,并不代表本站赞同其观点和对其真实性负责,本站只提供参考并不构成任何投资及应用建议。本站是信息平台,网站上部分文章为转载,并不用于任何商业目的,我们已经尽可能的对作者和来源进行了通告,但是能力有限或疏忽造成漏登,请及时联系我们,我们将根据著作权人的要求立即更正或者删除有关内容。

GMT+8, 2024-5-5 04:17 , Processed in 0.140086 second(s), 20 queries , Gzip On.

Powered by Discuz! X3.4

Copyright © 2001-2021, Tencent Cloud.

快速回复 返回顶部 返回列表