线程通信
线程通信是指线程间可以交互,指定信号,让线程执行或者等待
通过Object类中的方法完成通信
wait()
notify()
1、 同步方法
需求: 两个输出的方法,保证正常输出不被打断且达到一人一次输出的效果
public class Printer {
// 定义一个信号量// 1代表print1执行 2代表print2执行private int flag = 1;
/*** 线程通信的要求* 1) 要保证线程安全* 2) 线程等待方法是wait* 线程唤醒方法是notify* 3) 必须使用锁对象调用 通信的方法* ---------* 为什么,wait和notify这些线程通信的方法要设计在Object类?* 答:*/public synchronized void print1() throws InterruptedException {if (flag != 1){ // 信号不是1,说明不该print1执行,那就等待this.wait();}System.out.print(1 + " ");System.out.print(2 + " ");System.out.print(3 + " ");System.out.print(4 + " ");System.out.println( );
// 改变信号量flag = 2;// 通知处于等待状态的线程启动this.notify();}public synchronized void print2() throws InterruptedException {if (flag != 2) { // 信号不是2,说明不该print2执行,那就等待this.wait();}System.out.print("A ");System.out.print("B ");System.out.print("C ");System.out.print("D ");System.out.println( );
flag = 1;// 通知处于等待状态的线程启动this.notify();}
}public class TestPrinter {
public static void main(String[] args) {Printer p = new Printer( );// 开启一个线程new Thread(){@Overridepublic void run() {while(true){try {p.print1();} catch (InterruptedException e) {throw new RuntimeException(e);}}}}.start();
// 又开启一个线程new Thread(){@Overridepublic void run() {while(true){try {p.print2();} catch (InterruptedException e) {throw new RuntimeException(e);}}}}.start();}
}2、 同步代码块
再使用同步代码块演示一遍,再次确定一个结论
锁对象是谁,就使用哪个对象来调用wait和notify
public class Printer2 {
// 定义一个信号量// 1代表print1执行 2代表print2执行private int flag = 1;
/*** 线程通信的要求* 1) 要保证线程安全* 2) 线程等待方法是wait* 线程唤醒方法是notify* 3) 必须使用锁对象调用 通信的方法* ---------* 为什么,wait和notify这些线程通信的方法要设计在Object类?* 答:*/public void print1() throws InterruptedException {synchronized (Object.class) {if (flag != 1) { // 信号不是1,说明不该print1执行,那就等待Object.class.wait( );}System.out.print(1 + " ");System.out.print(2 + " ");System.out.print(3 + " ");System.out.print(4 + " ");System.out.println( );
// 改变信号量flag = 2;// 通知处于等待状态的线程启动Object.class.notify( );}}public void print2() throws InterruptedException {synchronized (Object.class) {if (flag != 2) { // 信号不是2,说明不该print2执行,那就等待Object.class.wait( );}System.out.print("A ");System.out.print("B ");System.out.print("C ");System.out.print("D ");System.out.println( );
flag = 1;// 通知处于等待状态的线程启动Object.class.notify( );}}
}补充: 目前这个代码可以保证两个线程通信,如果>= 3个线程,就不一定能按照预想顺序完成
原因是,线程过多,但是notify方法只能随机唤醒一个处于等待状态的线程
解决方案: 使用notifyAll
3、 wait和sleep
wait
是Object类中的方法
wait会让线程等待
wait方法必须在同步方法中使用
wait方法方法线程等待时,会让出资源,别的线程可以执行
sleep
是Thread类中的方法
sleep会让线程等待
方法同步或者不同步都可以使用
如果线程不安全,使用了sleep,会让出资源,别的线程执行
如果线程安全,使用了sleep,不会释放资源,别的线程不会执行,会阻塞 --> 抱着锁睡