关于多线程的问题 麻烦各位大佬进来看看 指导指导 十分感谢
问题: Baozipu类和Chihuo类都创建了Baozi的对象为什么main方法还要传个Baozi的对象参数进去呢?这里有点不解 难道是因为锁?package cn.XianCheng;public class Baozipu extends Thread{ //创建一个包子类型的变量 Baozi bz = new Baozi(); //使用带参构造方法为这个包子赋值 public Baozipu(Baozi cz){ this.bz = cz ; } //设置线程任务生产包子 @Override public void run() { while(true){ //必须使用同步技术保证只有一个线程在执行 这里用 同步代码块 synchronized(bz){ //判断有没有包子 if(bz.flag==true){ //有包子包子铺就进入等待状态 bz.notify(); try { bz.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } if(bz.flag==false){ //没有包子就生产包子 bz.pi = "薄皮"; bz.xian = "牛肉馅"; System.out.println("正在生产包子"+Thread.currentThread().getName()); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } bz.flag = true; System.out.println("包子铺已经生产好了:"+bz.pi+bz.xian+"包子"+Thread.currentThread().getName()); bz.notify(); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } } }}-------------------------------------------------------------------------------------------------------------
package cn.XianCheng;public class Chihuo extends Thread{ Baozi bz = new Baozi(); public Chihuo(Baozi cz){ this.bz = cz ; } @Override public void run() { while(true){ synchronized (bz){ if(bz.flag == false){ bz.notify(); try { bz.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } if(bz.flag == true){ System.out.println("正在吃:"+bz.pi+bz.xian+"包子"+Thread.currentThread().getName()); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } bz.flag = false ; System.out.println("吃完了"+Thread.currentThread().getName()); System.out.println("-------------------------------------"); bz.notify(); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } } }}--------------------------------------------------------------------------------------------------
package cn.XianCheng;public class Baozi { //皮 //馅 //包子的状态 String pi; String xian; boolean flag = false;}--------------------------------------------------------------------------------------------------
package cn.XianCheng;public class XianChengmain { public static void main(String[] args) { Baozi cz = new Baozi();//创建包子对象 new Baozipu(cz).start();//开启包子铺线程 new Chihuo(cz).start();//开启吃货线程 }} |
免责声明:本内容仅代表回答会员见解不代表天盟观点,请谨慎对待。
版权声明:作者保留权利,不代表天盟立场。
|
|
|
|
多线程执行(由线程调度器管理)是无序交替(无规律)。正常逻辑包子铺生产,吃货类消费,它们所用的是同一批包子。你现在的代码就好像,包子铺,吃货有各自的包子,但都只对第三方(主线程)运过来(new)的包子感兴趣。三个线程地位相等,然后抢着执行(线程启动顺序不代表执行顺序)。为确保成功消费包子,需要明确各线程执行体得到的结果有序,即生产(包子铺)包子 -> 运输(主线程)->消费(吃货)。因此需要线程通信协调,让各线程执行流有序,有了锁解决资源共享能不能用的问题,有了同步解决数据一致性问题,三个线程的通信也依赖于那个主线程包子实例,实例notify与wait方法则告诉其它线程该对象锁是否解除,当前线程是否需要阻塞,来控制线程间执行流。换而言之,如果你不传包子对象,相当于两个子线程,各自玩自家的包子,与主线程包子无关,那也没必要用到锁,用到同步,更不需要多线程了。 |
|
|
|
|