黑马程序员技术交流社区

标题: 请问我这个多生产多消费究竟哪里粗了问题？！竟然死锁！ [打印本页]

---

作者: librazeng    时间: 2013-5-15 22:47
标题: 请问我这个多生产多消费究竟哪里粗了问题？！竟然死锁！


//资源类
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();
        }
}
输出结果竟然有死锁和数组角标越界发生，求解释，谢谢！

---

作者: 萌小子    时间: 2013-5-16 00:21


你这个就是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

王盟盟 发表于 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

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]);//这样会不会更容易理解点

---

作者: 黑马伍哲沂    时间: 2013-5-16 10:52
瞎忙活了一阵。        发现错误所在的时候。  我只能说很无奈。

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

第一，角标越界是因为，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. }

复制代码

---

作者: librazeng    时间: 2013-5-16 16:33

黑马伍哲沂 发表于 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

librazeng 发表于 2013-5-16 16:33
你也没搞清楚吧。理想的结果是生产者和消费者交替输出，不断循环。
Thread-3。。消费者。。烤鸭1
Thread- ...

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

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

如果你是想生产一个，消费一个。  那就要修改很多地方了。

---

作者: librazeng    时间: 2013-5-16 18:56

黑马伍哲沂 发表于 2013-5-16 18:51
我多次运行后 没有出现过你说的这种情况。

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

哦？那你的运行结果是怎么样的？我这里总是莫名其妙的停掉。
多生产和多消费，我觉得理想的情况是：生产者只管生产，只要没有100只就继续生产；消费者只管消费，只要还有就继续消费。生产和消费都是多条线程同时运行，随机切换的，永续进行的。

---

作者: 黑马伍哲沂    时间: 2013-5-16 20:04

librazeng 发表于 2013-5-16 18:56
哦？那你的运行结果是怎么样的？我这里总是莫名其妙的停掉。
多生产和多消费，我觉得理想的情况是：生产 ...

貌似就是这样的啊。。

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

下载附件

2013-5-16 20:04 上传

---

作者: 殇_心。    时间: 2013-5-16 20:30
如果问题已解决，请及时修改分类，否则继续提问，谢谢合作！

---

作者: librazeng    时间: 2013-5-16 23:05

黑马伍哲沂 发表于 2013-5-16 20:04
貌似就是这样的啊。。

更神奇了，我这里全是这样。
资源：

1. public class ProducerConsumer {
   
2. 
   
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

librazeng 发表于 2013-5-16 23:05
更神奇了，我这里全是这样。
资源：结果：
Thread-1。。生产者。。烤鸭98

我之前提供的代码段里 增加了一个while啊，估计你没看到。。。。

---

作者: librazeng    时间: 2013-5-17 10:05

黑马伍哲沂 发表于 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;
   
4. 
   
5. public class ProducerConsumer {
   
6. 
   
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. }
    
48. 
    
49. 
    
50. class Producer implements Runnable {
    
51. 
    
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. }
    
66. 
    
67. 
    
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. }
    
79. 
    
80. public class ProducerConsumerDemo {
    
81. 
    
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

librazeng 发表于 2013-5-17 10:05
我的代码里增加了那个while(ture)啊，还是那样。。我觉得问题出在count满100之后的运行上。结果：
Thread ...

1. package com.itheima.reflect;
   
2. 
   
3. import java.util.concurrent.locks.Condition;
   
4. import java.util.concurrent.locks.Lock;
   
5. import java.util.concurrent.locks.ReentrantLock;
   
6. 
   
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();
    
16. 
    
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. }
    
67. 
    
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. }
    
100. 
     
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)

下载附件

2013-5-17 11:20 上传

---

作者: librazeng    时间: 2013-5-17 13:27

黑马伍哲沂 发表于 2013-5-17 11:21
把我代码给你看看。  你自己对照下。我的运行结果没任何问题。

谢谢，我成功了！！！
原来我混淆了一个类。。。

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2