线程调度与单例模式:wait、notify与懒汉模式解析
一.wait 和 notify(等待 和 通知)
引入 wait notify 就是为了能够从应用层面,干预到多个不同线程代码的执行顺序,可以让后执行的线程主动放弃被调度的机会,等先执行的线程完成后通知放弃调度的线程重新执行。
自助取款机
当取款机没有钱的时候,要想去取钱只能等别人进去存钱或者等银行的人过来放钱,否则他永远拿不到钱,他在出去之后又会进去取款,刚刚释放了锁,就又会参与到锁竞争,并且大概率他会一直拿到锁,这叫“线程饿死“,这种情况只是概率性事件,但还是会极大影响到其他线程运行,这个时候他为了不影响到其他人就会等待(wait),然后让后面如果存钱的人存了钱了,通知(notify)自己一声,自己就可以重新排队取钱,在没通知的这段时间,他就会一直在旁边等,不会去排队了。
join 和 wait
join 是等待另一个线程执行完,才继续执行
wait 则是等待另一个线程通过 notify 进行通知(不要求另一个线程必须执行完)
wait进入阻塞,只能说明自己释放锁了,至于是否有其他线程拿到锁,这是不能确定的
public class ThreadDemo25 {public static void main(String[] args) {//需要有一个统一的对象进行加锁,wait,nitifyObject locker = new Object();Thread t1 = new Thread(() -> {synchronized (locker){System.out.println("t1 wait 之前");try {locker.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(" t1 wait 之后");}});Thread t2 = new Thread(() -> {try {Thread.sleep(5000);synchronized (locker){System.out.println(" t2 notify 之前");locker.notify();System.out.println("t2 notify 之后");}} catch (InterruptedException e) {throw new RuntimeException(e);}});t1.start();t2.start();}
}
我们发现阻塞等待的原因是19行的wait
wait方法放到synchronized是因为要释放锁,前提是先加上锁
java特别约定要把notify放到synchronized中
由于线程的随机调度我们并不知道要先调用谁,如果先调用t2就没有线程去给t1唤醒了,所以要保证t1先执行,我们给t2加上了sleep
需要注意的是t2在notify之后并没有释放锁,而t1唤醒后会尝试加锁,所以会产生小小的阻塞。
notifyAll 唤醒这个对象所有等待的线程
假设有很多个线程,都使用同一个对象wait,针对这个对象进行notifyAll,此时就会全都唤醒
需要注意的是,这些线程在wait返回的时候,需要重新获取锁,就会因为锁竞争,是这些线程串行执行
wait 和 sleep
wait 提供了一个带有超时时间的版本
sleep 也是能指定时间
都是时间到了,就继续执行,解除阻塞了
wait 和 sleep 都可以被提前唤醒(虽然时间还没到),wait通过notify唤醒,sleep通过interrupt唤醒
使用wait 最主要的目标一定是不知道多少时间的前提下使用的,超时时间是为了兜底
使用sleep,一定是知道了多少时间的前提下使用的,虽然能提前唤醒,但是通过异常唤醒一般是程序出现一些特殊情况了
二.单例模式
单例模式是一种设计模式,遵守设计模式下限就有了兜底
1.饿汉模式
单例 == 单个实例(对象)
static 这个引用就是我们期望创建出唯一的实例的引用,static 静态的 指的是“类属性”
instance 就是 当前类对象里面持有的属性
每个类的类对象,只存在一个,类对象中的static属性,自然也是只有一个了
这时instance所指向的对象就是唯一的一个对象,其他代码要想使用这个类的实例,就需要通过这个方法来进行获取,而不是直接new一个出来。
这直接从根本上让其他人想new都new不了了
Sington内部代码早就把唯一的实例安排好了
class Singleton{private static Singleton instance = new Singleton();public static Singleton getInstance(){return instance;}private Singleton() {}
}
public class ThreadDemo26 {public static void main(String[] args) {Singleton s = Singleton.getInstance();}
}
上述代码成为“饿汉模式”单例模式一种简单的写法,在程序启动时,实例就创建了,所以就是用饿汉,创建实例非常早。
2.懒汉模式
创建实例的时机不一样了,创建实例的时机更晚,直到第一次使用的时候,才会创建实例
class SingletonLazy{//这个引用指向唯一实例,这个引用先初始化null,而不是立即创建实例private volatile static SingletonLazy instance = null;private static Object locker = new Object();public static SingletonLazy getInstance(){if(instance == null){//如果 Instance 为 NULL,就说明时首次调用,首次调用就需要考虑线程安全问题,就要加锁//如果非空的话就说明时后续调用就不必加锁synchronized (locker){if(instance == null) instance = new SingletonLazy();}}return instance;}private SingletonLazy(){}
}
public class ThreadDemo27 {public static void main(String[] args) {SingletonLazy s1 = SingletonLazy.getInstance();SingletonLazy s2 = SingletonLazy.getInstance();System.out.println(s1 == s2);}
}
如果是首次调用 getinstance,那么instance 引用 为null,进入if语句创建实例出来,后续再次调用返回的就已经是创建好的引用了。
饿汉模式和懒汉模式是否属于线程安全?
饿汉模式属于读操作在多线程是安全的。
但加入了懒汉模式就不一定了
这样就会导致实例被new 了两次,就又bug了。这时线程不安全,在多线程可能会new出多个实例
即使写成这样没有线程安全问题,但还是因为已经创建了实例,但还是进行加锁解锁操作使得效率降低。
所以if不一定要加在方法上,
我们加在了实例化对象上,这样就不会木讷的进行加锁,但是还有一个致命的问题就是整个方法不是原子了,这个时候我们就得考虑对象是否创建问题了。
我们得先理清一下思路了,现在我们第一个if是用来判断是不是第一次进行创建对象的,我们所面临的问题是在多线程下if后面的代码执行是不确定的,可能已经调用其他线程并创建了对象,所以我们得加一个判断是否创建了对象的语句
两个if代码一样但意义不同
第一个if是为了判定是否第一次创建对象,并加锁,第二个if是判断是否要创建对象
在创建对象过程中还涉及到了线程安全问题 ------- 指令重排序
调整原有代码的执行顺序,保证逻辑不管的前提下,提高程序的效率
创建对象这一行代码可以拆为三个步骤
1.申请一段内存空间
2.在这个内存上调用的方法。创建出这个实例
3.把这个内存地址赋值给instance引用变量
正常情况下是按照1,2,3顺序来执行的,但是编译器可能优化成1,3,2的顺序来执行
在单线程下1,2,3或者1,3,2都是可以的
但是如果是多线程就可能引入问题了!!!

在t1加锁之后t2进行阻塞,t1解锁后t2获得了锁,但在这个时候 t2判断不为空直接返回,但这个时候instance并未初始化,如果使用instance里面的属性或者方法就可能会出现错误,那难道2不是同时进行的吗?
注意:在执行完1,3后线程有可能也被调度走了,并未进行初始化。要想执行2可能会隔一段时间
在之前解决内存可见性时我们用到了volatile它的功能有两个
1.保证内存可见性,每次访问变量必须都要重新读取内存,而不会优化到寄存器/缓存中
2.禁止指令重排序,针对这个volatile 修饰的变量的读写操作相关指令,是不能被重排序的
回顾一些我们解决问题的步骤
首先
我们因为饿汉模式在多线程下,会出现二次实例化对象的操作,所以我们加上了锁,
第二次
我们因为即使加上了锁,但我们因为加锁的位置太消耗效率所以我们将锁的位置改变了,但我们无法判断对象是否被创建了,所以我们又加上了一层if,
第三次
我们了解了指令重排序,我们会遇到,对象创建但并未初始化,然后导致使用了没初始化对象的属性或者方法,出现了失误,这时候我们回想起之前解决内存可见性的volatile,它的另一个功能就是解决指令重排序所以我们加上了这个关键字,至此我们解决了这一系列问题