public class DoubleCheckSingleton {
/**
* 使用volatile,在多线程场景下,确保在判断null时,对所有线程可见
*/
private static volatile DoubleCheckSingleton uniqInstance;
/**
* 构造器私有,防止外部实例化该类
*/
private DoubleCheckSingleton() {}
/**
* 静态方法实例化,由于在类内部,可以调用构造器
*/
public static DoubleCheckSingleton getInstance(){
if (null == uniqInstance) { // 此处判断需要可见性volatile
synchronized (DoubleCheckSingleton.class) {
if (null == uniqInstance) {
//延迟初始化
uniqInstance = new DoubleCheckSingleton();
}
}
}
return uniqInstance;
}
}
最简单的线程安全集合实现,可以发现是通过以上线程安全共享的方式实现安全。
public class SafeSet {
// final
private final Set<Integer> myset = new HashSet<>(); //饿汉 一旦创建不会发布出去
// synchronized 同步访问
public synchronized void addInteger(Integer p){
myset.add(p);
}
public synchronized boolean containsInteger(Integer p) {
return myset.contains(p);
}
}
3.1 插入HashMap.put
如下,put方法有很多先检查后操作(需要原子性执行)的代码,由于put()和putVal()代码没有同步,所有的线程可以执行到此处代码,
(1)table==null? 初始化线程A执行check操作后,发生线程切换,B也check table==null操作,A、B都会resize()更新table,产生更新丢失!
if ((tab = table) == null || (n = tab.length) == 0)//(1)线程切换
n = (tab = resize()).length;
if ((p = tab[i = (n - 1) & hash]) == null)//(2)线程切换
tab = newNode(hash, key, value, null);
(2)tab==null? A 线程和 B 线程计算出相同的哈希值对应了相同的数组位置,此时该位置还没数据,然后对同一个数组位置,两个线程会同时 写入新的头结点,那B的写入操作就会覆盖 A 的写入,造成 A 的写入操作丢失。
3.1.1 HashMap 在扩容的时候
HashMap 插入后超过阈值会触发扩容resize操作,new一个新容量cap的数组,对原数组的键值对重新进行计算hash并写入新数组,然后指向新数组。
if (++size > threshold)// 线程切换
resize();
当A、B线程同时进来,检测到总数量超过阈值的时候就会同时触发 resize 操作,各自生成新的数组并 rehash 后赋给该 map 底层的数组,结果最终只有最后一个线程生成的新数组被赋给该 map 底层,其他线程的均会丢失。
JDK1.7甚至在扩容时并发有可能形成链表回路,导致后续操作遍历链表时有死循环!具体请戳
3.2 HashMap 在删除数据的时候
删除这一块可能会出现两种线程安全问题,
if ((tab = table) != null && (n = tab.length) > 0 &&(p = tab[index = (n - 1) & hash]) != null) {
Node<K,V> node = null, e; K k; V v;
// 找到对应节点
if (p.hash == hash && ((k = p.key) == key || (key != null && key.equals(k))))//切换线程(2)
node = p;
else if ((e = p.next) != null) {
if (p instanceof TreeNode)
node = ((TreeNode<K,V>)p).getTreeNode(hash, key); // 红黑树查找
else { // 链表查找
do {
if (e.hash == hash && ((k = e.key) == key || (key != null && key.equals(k)))) {
node = e;
break;
}
p = e;
} while ((e = e.next) != null);
}
}
if (node != null && (!matchValue || (v = node.value) == value || (value != null && value.equals(v)))) {
if (node instanceof TreeNode)
((TreeNode<K,V>)node).removeTreeNode(this, tab, movable); //删除树节点
else if (node == p)
tab[index] = node.next; // 删除链表头
else
p.next = node.next; // 删除链表中间
++modCount;
--size;
afterNodeRemoval(node);
return node;
}
}
return null;
线程A判断得到了指定的数组位置i并进入了循环,此时,线程B已经删掉位置i数据了,然后线程A那边就没了。但是删除的话,没了倒问题不大,只是A返回的就是null
当A、B线程同时操作同一个数组位置的时候,也都会先取得现在状态下该位置存储的头结点,然后各自去进行计算操作,之后再把结果写会到该数组位置去,其实写回的时候可能其他的线程已经就把这个位置给修改过了,就会覆盖其他线程的修改。
还有很多检查后操作的情况不能保证原子性操作,且有检查的时候不能保证可见性,检查到的值有可能是失效数,执行过程中不能保证其一致性状态,也不能保证符合程序设计者的预期!
且不安全地发布了内部字段,如keyset等,容易被其它现在在类外不可预期地修改!!
转自CSDN原文链接:https://blog.csdn.net/sarafina527/article/details/105040594
欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) | 黑马程序员IT技术论坛 X3.2 |