文章目录
- 一、线程安全问题-内存可见性
- 二、等待通知
- 2.1 wait()方法
- 2.2 notify()方法
一、线程安全问题-内存可见性
import java.util.Scanner;public class Demo27 {private static int count=0;//下面这段代码会出现内存的可见性问题//将从内存中读取count值的操作称为load 判断操作称为cmp//load和cmp的执行速度差了好几个数量级,在线程2开始执行代码提示输入数字时,线程1的while循环已经执行了很多遍//java编译器会自动给代码进行优化//导致load只是第一次时真正从内存中读取count值,其余都是从cpu的寄存器中读取//然而线程2修改count是在内存中进行修改,线程1根本访问不到count的值//可以在变量前加上volatile关键字来提醒编译器不要优化public static void main(String[] args) {Thread t1=new Thread(()->{while(count==0) {//}System.out.println("t1 执行结束");});Thread t2=new Thread(()->{Scanner scanner=new Scanner(System.in);System.out.println("输入数字:");count=scanner.nextInt();});t1.start();t2.start();}}
以上代码建立一个线程t1和线程t2,线程t1中建立一个循环,线程t2控制循环中的条件,按照预期,应该在t2中改变条件之后t1结束,整个程序也应该结束,但事实并非如此。
输入数字之后线程一仍然没有结束,这是因为count==0这个条件涉及到两个操作load和cmp,先将count的值从内存中载入cpu的寄存器进行比较,在线程二中还未输入数字时,线程一的循环已经执行很多次了,编译器发现这么多次count的值没有变化就会进行优化,只有第一个load会从内存中读count的值,剩余次数都是直接用寄存器中的值,这样既使后来在线程二当中改变了内存中的count的值,因为循环条件的count不从内存中读值因此访问不到修改后的count,线程一就会继续循环,从而程序就结束不了。如果不想让编译器进行优化,可以在count前面加上volatile关键字即可。
另外上述的内存可见性问题加锁,即包含在synchronized内也可以解决,因为加锁是比较重量的,load相对就不算慢了就不会触发优化。在循环内加上sout输出语句也是一个道理,sout相对于load更慢无法触发优化,自然也能解决上述的内存可见性的问题。
在网上查询资料还可以看到以一种JMM(java内存模型)角度来理解该问题的解答:
当t1执行的时候,会从工作内存中读取count而不是从主内存中。
t2修改count会先修改工作内存,再同步到主内存,但由于t1没有重新读主内存,导致t1没有感知到t2的修改。
二、等待通知
2.1 wait()方法
代码示例如下:
public class Demo28 {public static void main(String[] args) throws InterruptedException {Object locker = new Object();System.out.println("等待之前");//wait必须在synchronized内使用,会解锁并且让线程进入阻塞等待状态synchronized (locker) {locker.wait();}System.out.println("等待之后");}
}
wait方法是object类的方法,任何类对象都可以使用,它只能在锁内使用,如果执行wait方法会释放锁并且线程进入阻塞状态waiting。wait也有限时的参数,加上时间,会在限定时间内阻塞之后自动唤醒。
注意:wait和sleep一样可以被interrupt打断并且清空标志位。
2.2 notify()方法
通过notify方法来唤醒wait方法进入阻塞的线程,wait的线程状态从Waiting->Runnable->Blocked。
代码示例如下:
public class Demo29 {public static void main(String[] args) throws InterruptedException {Object locker = new Object();//1.wait和notify必须都在synchronized内//2.一个notify唤醒一个wait() 如果多个线程wait就使用多个notify或者notifyAll 这种唤醒时随机的//3.如果想唤醒指定线程也可以必须一对一写好锁对象//4.notify需要在wait之后Thread t1 = new Thread(() -> {System.out.println("t1 等待之前");synchronized (locker) {try {locker.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("t1 等待之后");});Thread t2 = new Thread(() -> {System.out.println("t2 通知之前");Scanner scanner = new Scanner(System.in);synchronized (locker) {
//控制阻塞,不输入数字t1仍是阻塞scanner.nextInt();locker.notify();}System.out.println("t2 通知之后");});t1.start();t2.start();}}
notify必须也在synchronized之内,并且一个notify只能唤醒对应的一个wait,如果多个线程wait就使用多个notify或者notifyAll,这种唤醒时随机的,唤醒的前提是通过一个对象来调用的wait及notify方法。如果想唤醒指定线程也可以必须一对一写好锁对象。另外notify的使用必须在wait之后,如果在wait之前使用notify不会有任何效果,不过wait就没有办法唤醒了。
使用相应的锁对象进行一对一唤醒代码示例如下:
public class Demo30 {public static void main(String[] args) throws InterruptedException {Object locker = new Object();Object locker1 = new Object();Thread t1 = new Thread(() -> {synchronized (locker) {System.out.println("t1等待之前");try {locker.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("t1等待之后");}});Thread t2 = new Thread(() -> {synchronized (locker1) {System.out.println("t2等待之前");try {locker1.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("t2等待之后");}});Thread t3 = new Thread(() -> {synchronized (locker) {//locker.notifyAll();locker.notify();}synchronized (locker1) {locker1.notify();}});t1.start();t2.start();Thread.sleep(1000);t3.start();}}