线程通信的目的是为了能够让线程之间相互发送信号。另外,线程通信还能够使得线程等待其它线程的信号,比如,线程B可以等待线程A的信号,这个信号可以是线程A已经处理完成的信号
Wait()方法
-中断方法的执行,使本线程等待,暂时让出cpu的使用权,并允许其他线程使用这个同步方法
Notify()方法
-唤醒由于使用这个同步方而处于等待线程的某一个结束等待
Notifyall()方法
唤醒所有由于使用这个同步方法而处于等待的线程结束等待
什么时候使用wait方法
当一个线程使用的同步方法中用到某个变量,而此变量又需要其他线程修改才能符合本线程的需要,那么可以在同步方法中使用wait()方法
在这里我以课上的一个例子为例,简述一下wait和notify的作用
我们已经知道开启多线程中,如卖票,每个窗口卖的票的顺序是随机的,如果我们有2个卖票窗口,规定100张票必须轮流卖,A窗口卖完一张票之后下一张票一定是由B窗口卖的,我们如何实现这个功能?
首先我想的是可以设置一个if语句,if(i%2==0)则线程1运行,否则则线程2运行,但是线程1和线程2的运行是随机的,不能规定由i的大小来确定谁运行
那我们可以用线程中的wait()和notify()
线程1运行完之后等待一下,然后线程2运行,线程2运行完之后再唤醒线程1然后再次
线程1运行完之后等待一下,然后线程2运行,线程2运行完之后再唤醒线程1
这样的话可以轮流运行线程1和线程2
我们已打印10个数为例子来编写程序,一共建2个类Myprint和MyprintTest
Myprint.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
public class Myprint implements Runnable { private int i= 0 ; @Override public void run() { try { print(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public synchronized void print() throws InterruptedException{ while (i< 10 ){ System.out.println(Thread.currentThread().getName()+ ":" +i); i++; notify(); try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } } |
结果如图
可以看到已经实现了线程1和线程2相互交替打印
只需理解运行过程即可
1
2
3
4
5
6
7
8
9
10
11
12
13
|
while (i< 10 ){ System.out.println(Thread.currentThread().getName()+ ":" +i); i++; notify(); try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } } |
当i<10时,打印线程1,然后执行唤醒,由于前面没有线程所以这一步不执行,然后线程1等待,执行完线程2唤醒前面的线程即线程1,然后打印线程1,
这个过程一直执行下去直到跳出循环,所以我们可以实现轮流运行
总结
以上就是本文关于浅谈线程通信wait,notify作用的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!
原文链接:http://blog.csdn.net/yutong5818/article/details/78426599