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

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

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第20届Android交流区 › 正文

请问我这个多生产多消费究竟哪里粗了问题？！竟然死锁！

© librazeng 中级黑马   /  2013-5-15 22:47  /  2260 人查看  /  14 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

本帖最后由 librazeng 于 2013-5-17 13:30 编辑

//资源类
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ProducerConsumer {
        /**生产者，消费者资源
         * @param args
         */
        private String[] items=new String[100];
        int count=0;
        int putptr=0;
        int takeptr=0;
        Lock lock=new ReentrantLock();//显示锁
        Condition con_pro=lock.newCondition();//获取两组锁的监视器
        Condition con_con=lock.newCondition();
        
        public void set(String name){
                lock.lock();
                try{
                        while(count==items.length)
                                try{con_pro.await();}catch(InterruptedException e){}
                        items[putptr]=name+ count++;
                        if(++putptr==items.length) putptr=0;
                        System.out.println(Thread.currentThread().getName()+"。。生产者。。"+items[putptr-1]);//这里究竟怎么打印才好啊？
                                con_con.signal();
                        }finally{
                                lock.unlock();
                        }
        }
        public void out(){
                lock.lock();
                try{
                        while(count==0)
                                try{con_con.await();}catch(InterruptedException e){}
                                String name=items[takeptr];
                                if(++takeptr==items.length) takeptr=0;
                                --count;
                                System.out.println(Thread.currentThread().getName()+"。。消费者。。"+name);
                                con_pro.signal();
                }finally{
                        lock.unlock();
                }
        }
}

//生产者类
class Producer implements Runnable {

        /**生产者
         * @param args
         */
        private ProducerConsumer r;
        Producer(ProducerConsumer r){
                this.r=r;
        }
        @Override
        public void run() {
                while(true){
                        r.set("烤鸭");
                }
        }
}

//消费者类
class Consumer implements Runnable{

        /**消费者
         * @param args
         */
private ProducerConsumer r;
Consumer(ProducerConsumer r){
        this.r=r;
    }
@Override
public void run() {
        r.out();
    }
}


//主函数类
public class ProducerConsumerDemo {

        /**生产者消费者主程序
         * @param args
         */
        public static void main(String[] args) {
                ProducerConsumer r=new ProducerConsumer();
                Producer p=new Producer(r);
                Consumer c=new Consumer(r);
                Thread t0=new Thread(p);
                Thread t1=new Thread(p);
                Thread t2=new Thread(c);
                Thread t3=new Thread(c);
                t0.start();
                t1.start();
                t2.start();
                t3.start();
        }
}
输出结果竟然有死锁和数组角标越界发生，求解释，谢谢！

评分

参与人数 1技术分 +1 收起 理由
Sword + 1

查看全部评分

锁监视器privatepublicimport

14 个回复

倒序浏览
萌小子 中级黑马 2013-5-16 00:21:02
| 只看该作者
沙发
本帖最后由 王盟盟 于 2013-5-16 00:58 编辑

你这个就是API中的例子么
if(++putptr==items.length) putptr=0;
                        System.out.println(Thread.currentThread().getName()+"。。生产者。。"+items[putptr-1]);//这里是数组越界的问题所在，你把putptr赋值为0了，items[putptr-1]自然就越界了
死锁的问题我调试了半天也没解决，等高手吧
回复 使用道具 举报
librazeng 中级黑马 2013-5-16 00:57:45
| 只看该作者
藤椅
王盟盟 发表于 2013-5-16 00:21
if(++putptr==items.length) putptr=0;
                        System.out.println(Thread.currentThread ...

谢谢！我把那几行调整如下：
        items[putptr]=name+ count++;
        System.out.println(Thread.currentThread().getName()+"。。生产者。。"+items[putptr]);
        if(++putptr==items.length) putptr=0;
输出结果：
Thread-1。。生产者。。烤鸭98
Thread-1。。生产者。。烤鸭99
Thread-3。。消费者。。烤鸭1
Thread-2。。消费者。。烤鸭2
Thread-0。。生产者。。烤鸭98
Thread-0。。生产者。。烤鸭99
输出停止，线程未停止，请问这又是为什么？
回复 使用道具 举报
萌小子 中级黑马 2013-5-16 01:00:08
| 只看该作者
板凳
本帖最后由 王盟盟 于 2013-5-16 01:01 编辑
librazeng 发表于 2013-5-16 00:57
谢谢！我把那几行调整如下：
        items=name+ count++;
        System.out.println(Thread.currentThread().getNam ...


这就是死锁了，问题出在哪，我也没弄清楚  等高手吧。我的建议是改为
if(putptr==items.length-1)
           putptr=0;
System.out.println(Thread.currentThread().getName()+"。。生产者。。"+items[putptr]);//这样会不会更容易理解点


评分

参与人数 1技术分 +1 收起 理由
Sword + 1 鼓励一下

查看全部评分

回复 使用道具 举报
黑马伍哲沂 高级黑马 2013-5-16 10:52:03
| 只看该作者
报纸
瞎忙活了一阵。        发现错误所在的时候。  我只能说很无奈。

一直以为是让线程等待的条件设置有问题。

第一，角标越界是因为，System.out.println(Thread.currentThread().getName() + "。。生产者。。" + items[putptr-1]);//这里-1，去掉改成items[putptr].
第二个问题，这里不叫死锁。死锁的基本条件是同步中嵌套同步。这里并不符合。程序挂着的原因应该是一部分线程在等待，另外一部分线程在锁外面进不来。   
贴一小段代码，你仔细看看和你的程序的不同之处。然后就知道程序问题出在哪了。其实很简单。
  1. // 生产者类
  2. class Producer implements Runnable
  3. {
  4.         private ProducerConsumer r;
  5.         Producer(ProducerConsumer r)
  6.         {
  7.                 this.r = r;
  8.         }
  9.         @Override public void run()
  10.         {
  11.                 while (true)
  12.                 {
  13.                         r.set("烤鸭");
  14.                 }
  15.         }
  16. }
  17. // 消费者类
  18. class Consumer implements Runnable
  19. {
  20.         private ProducerConsumer r;
  21.         Consumer(ProducerConsumer r)
  22.         {
  23.                 this.r = r;
  24.         }
  25.         @Override public void run()
  26.         {
  27.                 while (true)
  28.                 {
  29.                         r.out();
  30.                 }
  31.         }
  32. }
复制代码

评分

参与人数 1技术分 +1 收起 理由
Sword + 1 赞一个!

查看全部评分

回复 使用道具 举报
librazeng 中级黑马 2013-5-16 16:33:22
| 只看该作者
地板
黑马伍哲沂 发表于 2013-5-16 10:52
瞎忙活了一阵。        发现错误所在的时候。  我只能说很无奈。

一直以为是让线程等待的条件设置有问题。 ...

你也没搞清楚吧。理想的结果是生产者和消费者交替输出，不断循环。
Thread-3。。消费者。。烤鸭1
Thread-2。。消费者。。烤鸭2
Thread-0。。生产者。。烤鸭98
Thread-0。。生产者。。烤鸭99
出现这种结果，我不能完全解释。我只知道最后的烤鸭98、烤鸭99并不是重新生产的，而是items[0]和items[1]指向了已经存储在数组中的烤鸭98，烤鸭99.但在这之后，消费者为什么没有继续消费呢？
回复 使用道具 举报
黑马伍哲沂 高级黑马 2013-5-16 18:51:39
| 只看该作者
7#
librazeng 发表于 2013-5-16 16:33
你也没搞清楚吧。理想的结果是生产者和消费者交替输出，不断循环。
Thread-3。。消费者。。烤鸭1
Thread- ...

我多次运行后 没有出现过你说的这种情况。

我的理解是  你这里每生产100个，就消费100个。这样交替输出。

如果你是想生产一个，消费一个。  那就要修改很多地方了。
回复 使用道具 举报
librazeng 中级黑马 2013-5-16 18:56:56
| 只看该作者
8#
黑马伍哲沂 发表于 2013-5-16 18:51
我多次运行后 没有出现过你说的这种情况。

我的理解是  你这里每生产100个，就消费100个。这样交替输出 ...

哦？那你的运行结果是怎么样的？我这里总是莫名其妙的停掉。
多生产和多消费，我觉得理想的情况是：生产者只管生产，只要没有100只就继续生产；消费者只管消费，只要还有就继续消费。生产和消费都是多条线程同时运行，随机切换的，永续进行的。
回复 使用道具 举报
黑马伍哲沂 高级黑马 2013-5-16 20:04:08
| 只看该作者
9#
librazeng 发表于 2013-5-16 18:56
哦？那你的运行结果是怎么样的？我这里总是莫名其妙的停掉。
多生产和多消费，我觉得理想的情况是：生产 ...

貌似就是这样的啊。。

QQ图片20130516200336.jpg (97.67 KB, 下载次数: 0)

QQ图片20130516200336.jpg
回复 使用道具 举报
殇_心。 高级黑马 2013-5-16 20:30:54
| 只看该作者
10#
如果问题已解决，请及时修改分类，否则继续提问，谢谢合作！
回复 使用道具 举报
librazeng 中级黑马 2013-5-16 23:05:15
| 只看该作者
11#
黑马伍哲沂 发表于 2013-5-16 20:04
貌似就是这样的啊。。

更神奇了，我这里全是这样。
资源：
  1. public class ProducerConsumer {

  3.         /**生产者，消费者资源
  4.          * @param args
  5.          */
  6.         private String[] items=new String[100];
  7.         int count=0;
  8.         int putptr=0;
  9.         int takeptr=0;
  10.         Lock lock=new ReentrantLock();//显示锁
  11.         Condition con_pro=lock.newCondition();//获取2组锁的监视器
  12.         Condition con_con=lock.newCondition();
  13.        
  14.         public void set(String name){
  15.                 lock.lock();
  16.                 try{
  17.                                 while(count==items.length)
  18.                                         try{con_pro.await();}catch(InterruptedException e){}//线程阻塞，放弃了锁
  19.                                 items[putptr]=name+ ++count;
  20.                                 System.out.println(Thread.currentThread().getName()+"。。生产者。。"+items[putptr]);//
  21.                                 if(++putptr==items.length)
  22.                                         putptr=0;
  23.                                 con_con.signal();
  24.                         }finally{
  25.                                 lock.unlock();
  26.                         }
  27.         }
  28.         public void out(){
  29.                 lock.lock();
  30.                 try{
  31.                                 while(count==0)
  32.                                         try{con_con.await();}catch(InterruptedException e){}//线程阻塞，放弃了锁
  33.                                 String name=items[takeptr];
  34.                                 if(++takeptr==items.length)
  35.                                         takeptr=0;
  36.                                 --count;
  37.                                 System.out.println(Thread.currentThread().getName()+"。。消费者。。"+name);
  38.                                 con_pro.signal();
  39.                 }finally{
  40.                         lock.unlock();
  41.                 }
  42.         }
  43. }
复制代码
结果：
Thread-1。。生产者。。烤鸭98
Thread-1。。生产者。。烤鸭99
Thread-1。。生产者。。烤鸭100
Thread-2。。消费者。。烤鸭1
Thread-3。。消费者。。烤鸭2
Thread-0。。生产者。。烤鸭99
Thread-0。。生产者。。烤鸭100
输出停止....
回复 使用道具 举报
黑马伍哲沂 高级黑马 2013-5-17 07:28:46
| 只看该作者
12#
librazeng 发表于 2013-5-16 23:05
更神奇了，我这里全是这样。
资源：结果：
Thread-1。。生产者。。烤鸭98

我之前提供的代码段里 增加了一个while啊，估计你没看到。。。。
回复 使用道具 举报
librazeng 中级黑马 2013-5-17 10:05:34
| 只看该作者
13#
本帖最后由 librazeng 于 2013-5-17 13:31 编辑
黑马伍哲沂 发表于 2013-5-17 07:28
我之前提供的代码段里 增加了一个while啊，估计你没看到。。。。

我的代码里增加了那个while(ture)啊，还是那样。。我觉得问题出在count满100之后的运行上。
  1. import java.util.concurrent.locks.Condition;
  2. import java.util.concurrent.locks.Lock;
  3. import java.util.concurrent.locks.ReentrantLock;

  5. public class ProducerConsumer {

  7.         /**生产者，消费者资源
  8.          * @param args
  9.          */
  10.         private String[] items=new String[100];
  11.         int count=0;
  12.         int putptr=0;
  13.         int takeptr=0;
  14.         Lock lock=new ReentrantLock();//显示锁
  15.         Condition con_pro=lock.newCondition();//获取2组锁的监视器
  16.         Condition con_con=lock.newCondition();
  17.         
  18.         public void set(String name){
  19.                 lock.lock();
  20.                 try{
  21.                                 while(count==items.length)
  22.                                         try{con_pro.await();}catch(InterruptedException e){}//线程阻塞，放弃了锁
  23.                                 items[putptr]=name+ ++count;
  24.                                 System.out.println(Thread.currentThread().getName()+"。。生产者。。"+items[putptr]);//
  25.                                 if(++putptr==items.length)
  26.                                         putptr=0;
  27.                                 con_con.signal();
  28.                         }finally{
  29.                                 lock.unlock();
  30.                         }
  31.         }
  32.         public void out(){
  33.                 lock.lock();
  34.                 try{
  35.                                 while(count==0)
  36.                                         try{con_con.await();}catch(InterruptedException e){}//线程阻塞，放弃了锁
  37.                                 String name=items[takeptr];
  38.                                 if(++takeptr==items.length)
  39.                                         takeptr=0;
  40.                                 --count;
  41.                                 System.out.println(Thread.currentThread().getName()+"。。消费者。。"+name);
  42.                                 con_pro.signal();
  43.                 }finally{
  44.                         lock.unlock();
  45.                 }
  46.         }
  47. }


  50. class Producer implements Runnable {

  52.         /**生产者
  53.          * @param args
  54.          */
  55.         private ProducerConsumer r;
  56.         Producer(ProducerConsumer r){
  57.                 this.r=r;
  58.         }
  59.         @Override
  60.         public void run() {
  61.                 while(true){
  62.                         r.set("烤鸭");
  63.                 }
  64.         }
  65. }


  68. public class Output implements Runnable{<font color="#ff0000">//尼玛的，搞错了一类，眼珠挖掉。。。</font>
  69.         ThreadResource r;
  70.         Output(ThreadResource r){
  71.                 this.r=r;
  72.         }
  73.         public void run(){
  74.                 while(true){
  75.                         r.out();
  76.                 }
  77. }
  78. }

  80. public class ProducerConsumerDemo {

  82.         /**生产者消费者主程序
  83.          * @param args
  84.          */
  85.         public static void main(String[] args) {
  86.                 ProducerConsumer r=new ProducerConsumer();
  87.                 Producer p=new Producer(r);
  88.                 Consumer c=new Consumer(r);
  89.                 Thread t0=new Thread(p);
  90.                 Thread t1=new Thread(p);
  91.                 Thread t2=new Thread(c);
  92.                 Thread t3=new Thread(c);
  93.                 t0.start();
  94.                 t1.start();
  95.                 t2.start();
  96.                 t3.start();
  97.         }
  98. }
复制代码
结果：
Thread-0。。生产者。。烤鸭1
Thread-3。。消费者。。烤鸭1
Thread-0。。生产者。。烤鸭1
Thread-0。。生产者。。烤鸭2
Thread-0。。生产者。。烤鸭3
Thread-0。。生产者。。烤鸭4
Thread-0。。生产者。。烤鸭5
Thread-0。。生产者。。烤鸭6
Thread-0。。生产者。。烤鸭7
Thread-0。。生产者。。烤鸭8
Thread-0。。生产者。。烤鸭9
Thread-0。。生产者。。烤鸭10
Thread-0。。生产者。。烤鸭11
Thread-0。。生产者。。烤鸭12
Thread-0。。生产者。。烤鸭13
Thread-0。。生产者。。烤鸭14
Thread-0。。生产者。。烤鸭15
Thread-0。。生产者。。烤鸭16
Thread-0。。生产者。。烤鸭17
Thread-0。。生产者。。烤鸭18
Thread-0。。生产者。。烤鸭19
Thread-0。。生产者。。烤鸭20
Thread-0。。生产者。。烤鸭21
Thread-0。。生产者。。烤鸭22
Thread-0。。生产者。。烤鸭23
Thread-0。。生产者。。烤鸭24
Thread-0。。生产者。。烤鸭25
Thread-0。。生产者。。烤鸭26
Thread-0。。生产者。。烤鸭27
Thread-0。。生产者。。烤鸭28
Thread-0。。生产者。。烤鸭29
Thread-0。。生产者。。烤鸭30
Thread-0。。生产者。。烤鸭31
Thread-0。。生产者。。烤鸭32
Thread-0。。生产者。。烤鸭33
Thread-0。。生产者。。烤鸭34
Thread-0。。生产者。。烤鸭35
Thread-0。。生产者。。烤鸭36
Thread-0。。生产者。。烤鸭37
Thread-0。。生产者。。烤鸭38
Thread-0。。生产者。。烤鸭39
Thread-0。。生产者。。烤鸭40
Thread-0。。生产者。。烤鸭41
Thread-0。。生产者。。烤鸭42
Thread-0。。生产者。。烤鸭43
Thread-0。。生产者。。烤鸭44
Thread-0。。生产者。。烤鸭45
Thread-0。。生产者。。烤鸭46
Thread-0。。生产者。。烤鸭47
Thread-0。。生产者。。烤鸭48
Thread-0。。生产者。。烤鸭49
Thread-0。。生产者。。烤鸭50
Thread-0。。生产者。。烤鸭51
Thread-0。。生产者。。烤鸭52
Thread-0。。生产者。。烤鸭53
Thread-0。。生产者。。烤鸭54
Thread-0。。生产者。。烤鸭55
Thread-0。。生产者。。烤鸭56
Thread-0。。生产者。。烤鸭57
Thread-0。。生产者。。烤鸭58
Thread-0。。生产者。。烤鸭59
Thread-0。。生产者。。烤鸭60
Thread-0。。生产者。。烤鸭61
Thread-0。。生产者。。烤鸭62
Thread-0。。生产者。。烤鸭63
Thread-0。。生产者。。烤鸭64
Thread-0。。生产者。。烤鸭65
Thread-0。。生产者。。烤鸭66
Thread-0。。生产者。。烤鸭67
Thread-0。。生产者。。烤鸭68
Thread-0。。生产者。。烤鸭69
Thread-0。。生产者。。烤鸭70
Thread-0。。生产者。。烤鸭71
Thread-0。。生产者。。烤鸭72
Thread-0。。生产者。。烤鸭73
Thread-0。。生产者。。烤鸭74
Thread-0。。生产者。。烤鸭75
Thread-0。。生产者。。烤鸭76
Thread-0。。生产者。。烤鸭77
Thread-0。。生产者。。烤鸭78
Thread-0。。生产者。。烤鸭79
Thread-0。。生产者。。烤鸭80
Thread-0。。生产者。。烤鸭81
Thread-0。。生产者。。烤鸭82
Thread-0。。生产者。。烤鸭83
Thread-0。。生产者。。烤鸭84
Thread-0。。生产者。。烤鸭85
Thread-0。。生产者。。烤鸭86
Thread-0。。生产者。。烤鸭87
Thread-0。。生产者。。烤鸭88
Thread-0。。生产者。。烤鸭89
Thread-0。。生产者。。烤鸭90
Thread-0。。生产者。。烤鸭91
Thread-0。。生产者。。烤鸭92
Thread-0。。生产者。。烤鸭93
Thread-0。。生产者。。烤鸭94
Thread-0。。生产者。。烤鸭95
Thread-0。。生产者。。烤鸭96
Thread-0。。生产者。。烤鸭97
Thread-0。。生产者。。烤鸭98
Thread-0。。生产者。。烤鸭99
Thread-0。。生产者。。烤鸭100
Thread-2。。消费者。。烤鸭1
Thread-0。。生产者。。烤鸭100
输出停止，线程未停。
求解释啊。。。
回复 使用道具 举报
黑马伍哲沂 高级黑马 2013-5-17 11:21:14
| 只看该作者
14#
librazeng 发表于 2013-5-17 10:05
我的代码里增加了那个while(ture)啊，还是那样。。我觉得问题出在count满100之后的运行上。结果：
Thread ...
  1. package com.itheima.reflect;

  3. import java.util.concurrent.locks.Condition;
  4. import java.util.concurrent.locks.Lock;
  5. import java.util.concurrent.locks.ReentrantLock;

  7. class ProducerConsumer
  8. {
  9.         private String[] items = new String[100];
  10.         int count = 0;
  11.         int putptr = 0;
  12.         int takeptr = 0;
  13.         Lock lock = new ReentrantLock();// 显示锁
  14.         Condition con_pro = lock.newCondition();// 获取两组锁的监视器
  15.         Condition con_con = lock.newCondition();

  17.         public void set(String name)
  18.         {
  19.                 lock.lock();
  20.                 try
  21.                 {
  22.                         while (count == items.length)
  23.                                 try
  24.                                 {
  25.                                         con_pro.await();
  26.                                 }
  27.                                 catch (InterruptedException e)
  28.                                 {
  29.                                 }
  30.                         items[putptr] = name + count++;
  31.                         System.out.println(Thread.currentThread().getName() + "。。生产者。。" + items[putptr]);// 这里究竟怎么打印才好啊？
  32.                         if (++putptr == items.length)
  33.                                 putptr = 0;
  34.                         con_con.signal();
  35.                 }
  36.                 finally
  37.                 {
  38.                         lock.unlock();
  39.                 }
  40.         }
  41.         public void out()
  42.         {
  43.                 lock.lock();
  44.                 try
  45.                 {
  46.                         while (count == 0)
  47.                                 try
  48.                                 {
  49.                                         con_con.await();
  50.                                 }
  51.                                 catch (InterruptedException e)
  52.                                 {
  53.                                 }
  54.                         String name = items[takeptr];
  55.                         if (++takeptr == items.length)
  56.                                 takeptr = 0;
  57.                         --count;
  58.                         System.out.println(Thread.currentThread().getName() + "。。消费者。。" + name);
  59.                         con_pro.signal();
  60.                 }
  61.                 finally
  62.                 {
  63.                         lock.unlock();
  64.                 }
  65.         }
  66. }

  68. // 生产者类
  69. class Producer implements Runnable
  70. {
  71.         private ProducerConsumer r;
  72.         Producer(ProducerConsumer r)
  73.         {
  74.                 this.r = r;
  75.         }
  76.         @Override public void run()
  77.         {
  78.                 while (true)
  79.                 {
  80.                         r.set("烤鸭");
  81.                 }
  82.         }
  83. }
  84. // 消费者类
  85. class Consumer implements Runnable
  86. {
  87.         private ProducerConsumer r;
  88.         Consumer(ProducerConsumer r)
  89.         {
  90.                 this.r = r;
  91.         }
  92.         @Override public void run()
  93.         {
  94.                 while (true)
  95.                 {
  96.                         r.out();
  97.                 }
  98.         }
  99. }

  101. // 主函数类
  102. public class ProducerConsumerDemo
  103. {
  104.         public static void main(String[] args)
  105.         {
  106.                 ProducerConsumer r = new ProducerConsumer();
  107.                 Producer p = new Producer(r);
  108.                 Consumer c = new Consumer(r);
  109.                 Thread t0 = new Thread(p);
  110.                 Thread t1 = new Thread(p);
  111.                 Thread t2 = new Thread(c);
  112.                 Thread t3 = new Thread(c);
  113.                 t0.start();
  114.                 t1.start();
  115.                 t2.start();
  116.                 t3.start();
  117.         }
  118. }
复制代码
把我代码给你看看。  你自己对照下。我的运行结果没任何问题。

QQ图片20130517111935.jpg (105.3 KB, 下载次数: 0)

QQ图片20130517111935.jpg
回复 使用道具 举报
librazeng 中级黑马 2013-5-17 13:27:15
| 只看该作者
15#
黑马伍哲沂 发表于 2013-5-17 11:21
把我代码给你看看。  你自己对照下。我的运行结果没任何问题。

谢谢，我成功了！！！
原来我混淆了一个类。。。
回复 使用道具 举报
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马