继续刚才的话题看到了吧做了好几此饭才吃了一次,这不合理吧,我们怎么让做一次饭吃一次饭,通讯的机制是锁对象的wait(),notify()机制l来实现一下吧,class Fan{
private Fan() {
// TODO Auto-generated constructor stub
}
private static Fan fan=new Fan();//单例化 两个人做的做的同一件事
public static Fan getingstane(){
return fan;
}
private String attr="生的";//饭的属性方便演示
public void cook(){
synchronized (fan) {
if("熟了".equals(attr))
{
try {
fan.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
taomi();
zhengmi();
fan.notify();
}
}
private void taomi(){
attr="生的";
System.out.println("淘米"+"........"+attr);
}
private void zhengmi(){
attr="生的";
System.out.println("蒸米"+"........"+attr);
try {
Thread.currentThread().sleep(10);//模拟蒸饭的时间
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
attr="熟了";
System.out.println("做好了"+"........"+attr);
}
public void eat(){
synchronized (fan) {
if("生的".equals(attr)){
try {
fan.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
chengfan();
chifan();
fan.notify();
}
}
private void chengfan(){
System.out.println(attr+"....."+"盛好了");
}
private void chifan(){
System.out.println(attr+"....."+"吃完了");
attr="生的";//吃完了饭的属性又回到生的
}
}
红色的字体是修改的代码,简单实现了等待唤醒机制看看结果
淘米........生的
蒸米........生的
做好了........熟了
熟了.....盛好了
熟了.....吃完了
淘米........生的
蒸米........生的
做好了........熟了
熟了.....盛好了
熟了.....吃完了
淘米........生的
蒸米........生的
做好了........熟了
熟了.....盛好了
熟了.....吃完了
淘米........生的
蒸米........生的
做好了........熟了
熟了.....盛好了
熟了.....吃完了
淘米........生的
蒸米........生的
做好了........熟了
熟了.....盛好了
熟了.....吃完了看到了把做一次饭吃次饭,它的实现机制是什么,原理很简单,线程当一个线程持有一个锁对象,当锁对象吊用自己的wait()方法该线程冻结,比释放锁,让别的线程可以进来。所以这种方式只能用在同步当中哦!!掉用notify()方法可以唤醒线程池当中的了、第一个线程,这里只有两个线程,所以唤醒的一定是对方线程,保证下次一定会有两个识别不同表示的线程进入同步,以防全部冻结,程序进行执行不了。如果不知两个线程执行呢,我把线程这样分类,同样功能的线程成为本方线程,对应的执行另一个功能线程叫做对方线程。现在再两个线程看看把
new Thread(zuofan,"做饭线程1").start();
new Thread(zuofan,"做饭线程2").start();
new Thread(chifan,"吃饭线程1").start();
new Thread(chifan,"吃饭线程2").start();
加上线程的名字看的更清楚,看看结果
熟了.....盛好了吃饭线程2
熟了.....吃完了吃饭线程2
生的.....盛好了吃饭线程1
生的.....吃完了吃饭线程1
淘米........生的做饭线程2
蒸米........生的做饭线程2
做好了........熟了做饭线程2
熟了.....盛好了吃饭线程2
熟了.....吃完了吃饭线程2现在先来看看那刚才出现的情况吧这是怎么回事呢做么有乱了,分析一下,饭线程1准备吃饭发现饭是生的
if("生的".equals(attr)){
try {
fan.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
chengfan();
chifan();
fan.notify();
}
}
挂在了这,做饭线程进来做好饭,接着吃饭吃饭线程2来了他吃完了,唤醒等待整的线程,这里是饭线程1他醒了取得锁,从挂起来的地方开始执行,还进行判断吗,if语句是执行完语句体就继续只、执行下面的语句也就是chengfan();问题来了吧,这时候饭是生的的,没进行判断继续了,只要让他醒来就先判断自己该不该继续等带就行了,用whlie语句修改看看结果
蒸米........生的做饭线程1
做好了........熟了做饭线程1
熟了.....盛好了吃饭线程2
熟了.....吃完了吃饭线程2
淘米........生的做饭线程2
蒸米........生的做饭线程2
做好了........熟了做饭线程2
不乱了,但是怎么卡住了是这样的当对方线程都进入冻结,本方线程执行完,唤醒的还是本方线程那就挂了,怎么才能保证对方线程一定被唤醒呢,简单noyifyall();就Ok了;试试把,结果可行我就补贴出来了。
|