Java synchronized 实现唯一单例

在初始化数据库连接、hbase连接时,我们通常希望复用连接,而不是每次使用时都new 一个实例。也就是说一个hbase表名对应一个hbase client连接, 或者一个数据库连接字符串对应一个数据库连接。

但是在多线程下我们不加任何锁,或者加锁的方式不对,都有可能导致当个hbase表名new出多个实例。 关于单例模式的各种实现,请参考博文“高并发下线程安全的单例模式(最全最经典)”。本文只探讨synchronized 实现唯一单例的过程。

首先定义一个线程类MyThread, 新建多个线程,每个线程的功能就是通过表名获取实例MyInstance.getInstance(tableName)。MyThread的代码如下,  MyInstance的代码见方案一。


方案一:不加锁

输出结果:

Thread[Thread-0,5,main] round..

Thread[Thread-1,5,main] round..

Thread[Thread-2,5,main] round..

new instace

new instace

2017-05-05 17:32:23,919 INFO  [Thread-1]  (MyInstance:23) - 'Thread[Thread-1,5,main]' new a HbaseClient instance 'MyInstance@be81f6b' for tablename 'table1', hbaseClientStore = '{table1=MyInstance@71875333}'

2017-05-05 17:32:23,919 INFO  [Thread-2]  (MyInstance:23) - 'Thread[Thread-2,5,main]' new a HbaseClient instance 'MyInstance@71875333' for tablename 'table1', hbaseClientStore = '{table1=MyInstance@71875333}'

从输出结果中可以看出,3个线程new 了2个instance。 

方案二:加锁synchronized

输出与方案一的一样,也是new 了2个instance.  

Thread[Thread-1,5,main] round..

Thread[Thread-0,5,main] round..

Thread[Thread-2,5,main] round..

new instace

2017-05-05 17:38:37,199 INFO  [Thread-0]  (MyInstance:23) - 'Thread[Thread-0,5,main]' new a HbaseClient instance 'MyInstance@6c83e4d7' for tablename 'table1', hbaseClientStore = '{table1=MyInstance@6c83e4d7}'

new instace

2017-05-05 17:38:37,207 INFO  [Thread-1]  (MyInstance:23) - 'Thread[Thread-1,5,main]' new a HbaseClient instance 'MyInstance@1c500721' for tablename 'table1', hbaseClientStore = '{table1=MyInstance@1c500721}'

原因是程序按时间经历了如下过程:

1. Thread-1在12行时判断为false, 然后转第到15行准备锁住MyInstance.class

2. Thread-0执行到15行,锁住MyInstance.class, new了实例MyInstance@6c83e4d7, 释放锁。

3.Thread-1接着执行synchronized{} 中的代码,new了第二个实例MyInstance@1c500721,释放锁。

方案三:加锁synchronized + 二次判断

输出结果:

Thread[Thread-0,5,main] round..

Thread[Thread-2,5,main] round..

Thread[Thread-1,5,main] round..

new instace

2017-05-05 18:16:21,579 INFO  [Thread-0]  (MyInstance:23) - 'Thread[Thread-0,5,main]' new a HbaseClient instance 'MyInstance@785d445a' for tablename 'table1', hbaseClientStore = '{table1=MyInstance@785d445a}'

结果显示只new了一个实例。

按第二种方案执行流程执行第三种方案的代码流程:

1.第一个线程准备锁住类时,第二个线程抢先锁住类,new 了一个实例,释放锁

2.第一个线程获得锁,进入到synchronized{}代码块时,由于有第17行的二次判断,所以直接返回实例,不再new 实例。

结论:

在初始化instance时,只加synchronized并不能实现唯一单例, “synchronized + 二次判断” 才实现唯一单例。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,839评论 18 399
  • 本文主要讲了java中多线程的使用方法、线程同步、线程数据传递、线程状态及相应的一些线程函数用法、概述等。 首先讲...
    李欣阳阅读 2,521评论 1 15
  • Java多线程学习 [-] 一扩展javalangThread类 二实现javalangRunnable接口 三T...
    影驰阅读 3,018评论 1 18
  • 一. Java基础部分.................................................
    wy_sure阅读 3,870评论 0 11
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,253评论 19 139