A股上市公司传智教育（股票代码 003032）旗下技术交流社区北京昌平校区

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第4届JavaEE+hadoop大数据技术交流 › 正文

关于多线程的一个程序

© 夏凡 中级黑马   /  2013-5-2 22:02  /  1403 人查看  /  4 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

本帖最后由 夏凡 于 2013-5-8 19:19 编辑

程序运行时报错，寻求高手解答，谢谢！
  1. import java.util.concurrent.locks.*;
  2. class Goods
  3. {
  4.         private String name;
  5.         private int num = 200;
  6.         private boolean flag = false;

  8.         private Lock lock = new ReentrantLock();
  9.         private Condition condition_pro = lock.newCondition();
  10.         private Condition condition_con = lock.newCondition();
  11.         
  12.         public void setInfo(String name) throws InterruptedException//因为没写catch
  13.         {
  14.                 lock.lock();
  15.                 try
  16.                 {
  17.                         while(flag)
  18.                         {
  19.                                 condition_pro.await();
  20.                         }

  22.                         this.name = name+"----"+num--;

  24.                         System.out.println(Thread.currentThread().getName() + "----生产者----" + this.name);

  26.                         this.flag = true;
  27.                         condition_con.signal();
  28.                 }
  29.                 finally
  30.                 {
  31.                         lock.unlock();
  32.                 }
  33.         }

  35.         public void getInfo()throws InterruptedException
  36.         {
  37.                 try
  38.                 {
  39.                         while(!flag)//此处需要用到while，循环判断
  40.                         {
  41.                                 condition_con.await();
  42.                         }

  44.                         System.out.println(Thread.currentThread().getName() + "----消费者----" + this.name);

  46.                         this.flag = false;
  47.                         condition_pro.signal();
  48.                 }
  49.                 finally
  50.                 {
  51.                         lock.unlock();
  52.                 }
  53.         }
  54. }

  56. class Producer implements Runnable//创建线程
  57. {
  58.         private Goods apple;

  60.         Producer(Goods apple_ipad)//有什么用啊？
  61.         {
  62.                 apple = apple_ipad;
  63.         }

  65.         public void run()
  66.         {
  67.                 while(true)
  68.                 {
  69.                         try
  70.                         {
  71.                                 apple.setInfo("苹果");
  72.                         }
  73.                         catch (InterruptedException e)
  74.                         {
  75.                         }
  76.                 }
  77.         }
  78. }

  80. class Consumer implements Runnable
  81. {
  82.         private Goods apple;

  84.         Consumer(Goods apple_ipad)
  85.         {
  86.                 apple = apple_ipad;
  87.         }

  89.         public void run()
  90.         {
  91.                 while(true)
  92.                 {
  93.                         try
  94.                         {
  95.                                 apple.getInfo();
  96.                         }
  97.                         catch (InterruptedException e)
  98.                         {
  99.                         }
  100.                 }
  101.         }
  102. }

  104. class ProducerConsumer2
  105. {
  106.         public static void main(String[] args)
  107.         {
  108.                 Goods ipad4 = new Goods();

  110.                 Producer p = new Producer(ipad4);
  111.                 Consumer c = new Consumer(ipad4);

  113.                 Thread tp1 = new Thread( p, "factory1");
  114.                 Thread tp2 = new Thread( p, "factory2");

  116.                 Thread tc1 = new Thread(c, "buyer1");
  117.                 Thread tc2 = new Thread(c, "buyer2");

  119.                 tp1.start();
  120.                 tp2.start();

  122.                 tc1.start();
  123.                 tc2.start();
  124.         }
  125. }
复制代码

评分

参与人数 1技术分 +1 收起 理由
曹睿翔 + 1 鼓励

查看全部评分

多线程运行时报错

4 个回复

正序浏览
刘学明　　　 高级黑马 2013-5-8 10:30:04
| 只看该作者
报纸
  1. import java.util.concurrent.locks.*;
  2. class Goods
  3. {
  4.         private String name;
  5.         private int num = 200;
  6.         private boolean flag = false;

  8.         private Lock lock = new ReentrantLock();
  9.         private Condition condition_pro = lock.newCondition();
  10.         private Condition condition_con = lock.newCondition();
  11.         
  12.         public void setInfo(String name) throws InterruptedException//因为没写catch
  13.         {
  14.                 lock.lock();
  15.                 try
  16.                 {
  17.                         while(num>1)
  18.                         {
  19.                                 while(flag)
  20.                         {
  21.                                 condition_pro.await();
  22.                         }

  24.                         this.name = name+"----"+num--;

  26.                         System.out.println(Thread.currentThread().getName() + "----生产商----" + this.name);

  28.                         this.flag = true;
  29.                      
  30.                         condition_con.signal();
  31.                         }
  32.                         if(num==0){
  33.                                 System.out.println(name+"产品已经生产完毕！");
  34.                                 System.exit(0);
  35.                         }
  36.                         
  37.                 }
  38.                 finally
  39.                 {
  40.                         lock.unlock();
  41.                 }
  42.         }

  44.         public void getInfo()throws InterruptedException
  45.         {
  46.                         lock.lock();//  消费商品这没有上锁！
  47.                 try
  48.                 {
  49.                         while(!flag)//此处需要用到while，循环判断
  50.                         {
  51.                                 condition_con.await();
  52.                         }

  54.                         System.out.println(Thread.currentThread().getName() + "----消费者----" + this.name);

  56.                         this.flag = false;
  57.                         condition_pro.signal();
  58.                 }
  59.                 finally
  60.                 {
  61.                         lock.unlock();
  62.                 }
  63.         }
  64. }

  66. class Producer implements Runnable//创建线程
  67. {
  68.         private Goods apple;

  70.         Producer(Goods apple_ipad)//有什么用啊？    //  将产品对象Goods传入到生产商 ，对Goods进行生产。
  71.         {
  72.                 apple = apple_ipad;
  73.         }

  75.         public void run()
  76.         {
  77.                 while(true)
  78.                 {
  79.                         try
  80.                         {
  81.                                 apple.setInfo("苹果");
  82.                         }
  83.                         catch (InterruptedException e)
  84.                         {
  85.                         }
  86.                 }
  87.         }
  88. }

  90. class Consumer implements Runnable
  91. {
  92.         private Goods apple;

  94.         Consumer(Goods apple_ipad)
  95.         {
  96.                 apple = apple_ipad;
  97.         }

  99.         public void run()
  100.         {
  101.                 while(true)
  102.                 {
  103.                         try
  104.                         {
  105.                                 apple.getInfo();
  106.                         }
  107.                         catch (InterruptedException e)
  108.                         {
  109.                         }
  110.                 }
  111.         }
  112. }

  114. class ProducerConsumer2
  115. {
  116.         public static void main(String[] args)
  117.         {
  118.                 Goods ipad4 = new Goods();

  120.                 Producer p = new Producer(ipad4);
  121.                 Consumer c = new Consumer(ipad4);

  123.                 Thread tp1 = new Thread( p, "factory1");
  124.                 Thread tp2 = new Thread( p, "factory2");

  126.                 Thread tc1 = new Thread(c, "buyer1");
  127.                 Thread tc2 = new Thread(c, "buyer2");

  129.                 tp1.start();
  130.                 tp2.start();

  132.                 tc1.start();
  133.                 tc2.start();
  134.         }
  135. }
复制代码

点评

夏凡
是的，谢谢！！！  发表于 2013-5-8 19:20
回复 使用道具 举报
夏凡 中级黑马 2013-5-8 09:32:42
| 只看该作者
板凳
李松柏 发表于 2013-5-3 20:29
Producer(Goods apple_ipad)//有什么用啊？
        {
                apple = apple_ipad;

我的问题主要不是这，是这个程序运行会报错，还是谢谢你
回复 使用道具 举报
黑马伍哲沂 高级黑马 2013-5-3 22:47:44
| 只看该作者
藤椅
程序 第36行  少一句：lock.lock();{:soso_e127:}

点评

夏凡
犀利！搞定！灰常感谢  发表于 2013-5-8 09:37
回复 使用道具 举报
爪哇攻城狮 中级黑马 2013-5-3 20:29:34
| 只看该作者
沙发
Producer(Goods apple_ipad)//有什么用啊？
        {
                apple = apple_ipad;
        }

有参构造函数，给apple初始化
回复 使用道具 举报
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马