public class Test4 {
        public static void main(String[] args) {
                Resource r = new Resource();
                Producer pro = new Producer(r);
                Cousumer con = new Cousumer(r);
                Thread t1 = new Thread(pro);
                Thread t2 = new Thread(con);
                t1.start();
                t2.start();
        }
}

class Resource {
        private String name;
        private int count = 1;// 编号
        private boolean flag = false;

        public synchronized void set(String name) {
                if (flag) {
                        try {
                                this.wait();
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                }
                this.name = name + "--" + count++;
                System.out.println(Thread.currentThread().getName() + "..生产者"
                                + this.name);
                flag = true;
                this.notify();
        }

        public synchronized void out() {
                if (!flag) {
                        try {
                                this.wait();
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                }
                System.out.println(Thread.currentThread().getName() + "..消费者"
                                + this.name);
                flag = false;
                this.notify();
        }
}

class Producer implements Runnable {
        private Resource res;

        public Producer(Resource res) {
                this.res = res;
        }

        public void run() {
                // TODO Auto-generated method stub
                while (true) {
                        res.set("+商品+");
                }
        }
}

class Cousumer implements Runnable {// 消费者
        private Resource res;

        public Cousumer(Resource res) {
                this.res = res;
        }

        public void run() {
                // TODO Auto-generated method stub
                res.out();
        }

}

1. public class Test4 {
   
2.         public static void main(String[] args) {
   
3.                 Resource r = new Resource();
   
4.                 Producer pro = new Producer(r);
   
5.                 Cousumer con = new Cousumer(r);
   
6.                 Thread t1 = new Thread(pro);
   
7.                 Thread t2 = new Thread(con);
   
8.                 t1.start();
   
9.                 t2.start();
   
10.         }
    
11. }
    
12. 
    
13. class Resource {
    
14.         private String name;
    
15.         private int count = 1;// 编号
    
16.         private boolean flag = false;
    
17. 
    
18.         public synchronized void set(String name) {
    
19.                 if (flag) {
    
20.                         try {
    
21.                                 this.wait();
    
22.                         } catch (InterruptedException e) {
    
23.                                 // TODO Auto-generated catch block
    
24.                                 e.printStackTrace();
    
25.                         }
    
26.                 }
    
27.                 this.name = name + "--" + count++;
    
28.                 System.out.println(Thread.currentThread().getName() + "..生产者"
    
29.                                 + this.name);
    
30.                 flag = true;
    
31.                 this.notify();
    
32.         }
    
33. 
    
34.         public synchronized void out() {
    
35.                 if (!flag) {
    
36.                         try {
    
37.                                 this.wait();
    
38.                         } catch (InterruptedException e) {
    
39.                                 // TODO Auto-generated catch block
    
40.                                 e.printStackTrace();
    
41.                         }
    
42.                 }
    
43.                 System.out.println(Thread.currentThread().getName() + "..消费者"
    
44.                                 + this.name);
    
45.                 flag = false;
    
46.                 this.notify();
    
47.         }
    
48. }
    
49. 
    
50. class Producer implements Runnable {
    
51.         private Resource res;
    
52. 
    
53.         public Producer(Resource res) {
    
54.                 this.res = res;
    
55.         }
    
56. 
    
57.         public void run() {
    
58.                 // TODO Auto-generated method stub
    
59.                 while (true) {
    
60.                         res.set("+商品+");
    
61.                 }
    
62.         }
    
63. }
    
64. 
    
65. class Cousumer implements Runnable {// 消费者
    
66.         private Resource res;
    
67. 
    
68.         public Cousumer(Resource res) {
    
69.                 this.res = res;
    
70.         }
    
71. 
    
72.         public void run() {
    
73.                 // TODO Auto-generated method stub
    
74.                 res.out();
    
75.         }
    
76. 
    
77. }
    

复制代码

搞了半天，郁闷了为什么叫不醒消费者呢，查看了这俩线程的状态之后才发现，消费者这个线程执行一次后就结束了，退出了。仔细一瞅，Cousumer中的run方法没有加判断，，，晕啊

楼主您好，帖子长时间没有动态我已经将您的帖子改成已解决。如有问题请私密我哦~