问题描述：有一个大型商场，该商场拥有4个超级商店和6个超级生产机器人和一个能存货300个商品的仓库
4个超级商店24小时营业不停运
6个超级生产机器人编号为1~6，编号为1~3的生产机器人和编号为4~6的生产机器人轮流生产商品
轮流间隔为1秒钟。生产的商品是编号唯一，名称随机的。
每隔5秒钟，6个超级生产机器人全部停止生产，并进行检修，时间为20秒
20秒之后，6个超级生产机器人继续进行间隔高速生产商品
而4个超级商店一直在从仓库中取商品，并卖出。
----------------------------------------------------------
运行截图：

1. import java.util.concurrent.locks.*;
   
2. 
   
3. class ProducerConsumer4
   
4. {
   
5.     public static void main(String[] args)
   
6.     {
   
7.         Resource r=new Resource();
   
8.         Producer p1=new Producer("超级生产机器人1",r);
   
9.         Producer p2=new Producer("超级生产机器人2",r);
   
10.         Producer p3=new Producer("超级生产机器人3",r);
    
11.         Producer p4=new Producer("超级生产机器人4",r);
    
12.         Producer p5=new Producer("超级生产机器人5",r);
    
13.         Producer p6=new Producer("超级生产机器人6",r);
    
14.         Consumer c=new Consumer(r);
    
15.         p4.work();
    
16.         p5.work();
    
17.         p6.work();
    
18.         new Thread(c,"超级商店1").start();
    
19.         new Thread(c,"超级商店2").start();
    
20.         new Thread(c,"超级商店3").start();
    
21.         new Thread(c,"超级商店4").start();
    
22.         int count=0;
    
23.         while(true){
    
24.             p4.over();
    
25.             p5.over();
    
26.             p6.over();
    
27.             p1.work();
    
28.             p2.work();
    
29.             p3.work();
    
30.             try{Thread.sleep(1000);}catch(Exception e){}
    
31.             p1.over();
    
32.             p2.over();
    
33.             p3.over();
    
34.             p4.work();
    
35.             p5.work();
    
36.             p6.work();
    
37.             count=(count+1)%10;
    
38.             if(count==5){
    
39.                 p1.over();
    
40.                 p2.over();
    
41.                 p3.over();
    
42.                 p4.over();
    
43.                 p5.over();
    
44.                 p6.over();
    
45.                 try{Thread.sleep(20000);}catch(Exception e){}
    
46.             }
    
47.         }
    
48.     }
    
49. }
    
50. class commodity
    
51. {
    
52.     String name;//产品名称
    
53.     int number;//产品编号
    
54.     commodity(int num){
    
55.         this.name=creatRandomName();
    
56.         this.number=num;
    
57.     }
    
58.     public static String creatRandomName(){
    
59.         String[] name={"茶杯","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
    
60.         return name[(int)(Math.random()*name.length)];
    
61.     }
    
62. }
    
63. class Resource
    
64. {
    
65.     final commodity[] storehouse = new commodity[100];//仓库中的保存的货物
    
66.     int total;//仓库中当前的货物总数
    
67.     int proPointer;//生产者当前指针
    
68.     int conPointer;//消费者当前指针
    
69.    
    
70.     int count;//产品编号
    
71.     private Lock lock=new ReentrantLock();
    
72.     private Condition pro=lock.newCondition();
    
73.     private Condition con=lock.newCondition();
    
74.     public void produce() throws InterruptedException {
    
75.         lock.lock();
    
76.         try{
    
77.             while(total==storehouse.length)
    
78.                 pro.await();
    
79.             storehouse[proPointer]=new commodity(count++);
    
80.             System.out.println(Thread.currentThread().getName()+":生产一个商品,信息如下：");
    
81.             System.out.println("产品名称："+storehouse[proPointer].name+"，产品编号："+storehouse[proPointer].number);
    
82.             System.out.println("-----------------------------------------------------");
    
83.             proPointer=(proPointer+1)%storehouse.length;
    
84.             ++total;
    
85.             con.signal();
    
86.         }finally{
    
87.             lock.unlock();
    
88.         }
    
89.     }
    
90.     public void consume() throws InterruptedException {
    
91.         lock.lock();
    
92.         try{
    
93.             while(total==0)
    
94.                 con.await();
    
95.             commodity temp=storehouse[conPointer];
    
96.             conPointer=(conPointer+1)%storehouse.length;
    
97.             --total;
    
98.             System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
    
99.             System.out.println("产品名称："+temp.name+"，产品编号为："+temp.number);
    
100.             System.out.println("-----------------------------------------------------");
     
101.             pro.signal();
     
102.         }finally{
     
103.              lock.unlock();
     
104.         }
     
105.     }
     
106. }
     
107. class Producer
     
108. {
     
109.     private final Resource r;
     
110.     private boolean flag;
     
111.     private final String name;
     
112.     private Thread t;
     
113.     Producer(String name,Resource r){
     
114.         this.name=name;
     
115.         this.r=r;
     
116.     }
     
117. 
     
118.     public void work(){
     
119.         flag=true;
     
120.         t=new Thread(name){
     
121.             public void run(){
     
122.                 while(flag){
     
123.                     try{
     
124.                         r.produce();
     
125.                     }catch (InterruptedException e){
     
126.                         System.out.println(Thread.currentThread().getName()+":我休息1秒钟");
     
127.                     }
     
128.                 }
     
129.             }
     
130.         };
     
131.         t.start();
     
132.     }
     
133.     public void over(){
     
134.         flag=false;
     
135.         t.interrupt();
     
136.     }
     
137. }
     
138. class Consumer implements Runnable
     
139. {
     
140.     private final Resource r;
     
141.     Consumer(Resource r){
     
142.         this.r=r;
     
143.     }
     
144.     public void run(){
     
145.         while(true){
     
146.             try{
     
147.                 r.consume();
     
148.             }catch (InterruptedException e){
     
149.                 e.toString();
     
150.             }
     
151.         }
     
152.     }
     
153. }

复制代码

很给力，今天晚上太晚了，没时间仔细看了，不过我下一期的技术分活动就是多线程。在我的题目中是有预告的。

王震阳老师 发表于 2014-12-26 00:29
很给力，今天晚上太晚了，没时间仔细看了，不过我下一期的技术分活动就是多线程。在我的题目中是有预告的。 ...

难得得到老师的认可:lol，今天起床又稍微作了一点改进。细节问题还望王老师指导一下。
运行效果：

代码如下：

1. import java.util.concurrent.locks.*;
   
2. 
   
3. class ProducerConsumer4
   
4. {
   
5.     public static void main(String[] args)
   
6.     {
   
7.         Resource r=new Resource();
   
8.         Producer p1=new Producer("超级生产机器人1",r);
   
9.         Producer p2=new Producer("超级生产机器人2",r);
   
10.         Producer p3=new Producer("超级生产机器人3",r);
    
11.         Producer p4=new Producer("超级生产机器人4",r);
    
12.         Producer p5=new Producer("超级生产机器人5",r);
    
13.         Producer p6=new Producer("超级生产机器人6",r);
    
14.         Consumer c=new Consumer(r);
    
15.         p4.work();
    
16.         p5.work();
    
17.         p6.work();
    
18.         new Thread(c,"超级商店1").start();
    
19.         new Thread(c,"超级商店2").start();
    
20.         new Thread(c,"超级商店3").start();
    
21.         new Thread(c,"超级商店4").start();
    
22.         int count=0;
    
23.         while(true){
    
24.             p4.over();
    
25.             p5.over();
    
26.             p6.over();
    
27.             p1.work();
    
28.             p2.work();
    
29.             p3.work();
    
30.             try{Thread.sleep(1000);}catch(Exception e){}
    
31.             p1.over();
    
32.             p2.over();
    
33.             p3.over();
    
34.             p4.work();
    
35.             p5.work();
    
36.             p6.work();
    
37.             count=(count+1)%10;
    
38.             if(count==5){
    
39.                 p1.over();
    
40.                 p2.over();
    
41.                 p3.over();
    
42.                 p4.over();
    
43.                 p5.over();
    
44.                 p6.over();
    
45.                 System.out.println("<-----所有机器人集体休息20秒------>");
    
46.                 try{Thread.sleep(20000);}catch(Exception e){}
    
47.             }
    
48.         }
    
49.     }
    
50. }
    
51. class commodity
    
52. {
    
53.     String name;//产品名称
    
54.     int number;//产品编号
    
55.     commodity(int num){
    
56.         this.name=creatRandomName();
    
57.         this.number=num;
    
58.     }
    
59.     public static String creatRandomName(){
    
60.         String[] name={"茶杯","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
    
61.         return name[(int)(Math.random()*name.length)];
    
62.     }
    
63. }
    
64. class Resource
    
65. {
    
66.     final commodity[] storehouse = new commodity[100];//仓库中的保存的货物
    
67.     int total;//仓库中当前的货物总数
    
68.     int proPointer;//生产者当前指针
    
69.     int conPointer;//消费者当前指针
    
70.    
    
71.     int count;//产品编号
    
72.     private Lock lock=new ReentrantLock();
    
73.     private Condition pro=lock.newCondition();
    
74.     private Condition con=lock.newCondition();
    
75.     public void produce() throws InterruptedException {
    
76.         lock.lock();
    
77.         try{
    
78.             while(total==storehouse.length)
    
79.                 pro.await();
    
80.             storehouse[proPointer]=new commodity(count++);
    
81.             System.out.println(Thread.currentThread().getName()+":生产一个商品,信息如下：");
    
82.             System.out.println("产品名称："+storehouse[proPointer].name+";产品编号："+storehouse[proPointer].number);
    
83.             System.out.println("-----------------------------------------------------");
    
84.             proPointer=(proPointer+1)%storehouse.length;
    
85.             ++total;
    
86.             con.signal();
    
87.         }finally{
    
88.             lock.unlock();
    
89.         }
    
90.     }
    
91.     public void consume() throws InterruptedException {
    
92.         lock.lock();
    
93.         try{
    
94.             while(total==0)
    
95.                 con.await();
    
96.             commodity temp=storehouse[conPointer];
    
97.             conPointer=(conPointer+1)%storehouse.length;
    
98.             --total;
    
99.             System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
    
100.             System.out.println("产品名称："+temp.name+";产品编号为："+temp.number);
     
101.             System.out.println("购买人信息：");
     
102.             System.out.println("姓名："+person.getName()+";性别："+person.getSex());
     
103.             System.out.println("手机号:"+person.getCellphoneNumber());
     
104.             System.out.println("-----------------------------------------------------");
     
105.             pro.signal();
     
106.         }finally{
     
107.              lock.unlock();
     
108.         }
     
109.     }
     
110. }
     
111. class person
     
112. {
     
113.     public static final String[] firstName={"王","李","张","刘", "陈","杨","黄","赵", "周","吴","徐","孙", "马","胡","朱","郭", "何","罗","高","林",
     
114.                             "郑","梁","谢","唐", "许","冯","宋","韩", "邓","彭","曹","曾", "田","于","肖","潘", "袁","董","叶","杜",
     
115.                             "丁","蒋","程","余", "吕","魏","蔡","苏", "任","卢","沈","姜", "姚","钟","崔","陆", "谭","汪","石","付",
     
116.                             "贾","范","金","方", "韦","夏","廖","侯", "白","孟","邹","秦", "尹","江","熊","薛", "邱","闫","段","雷",
     
117.                             "季","史","陶","毛", "贺","龙","万","顾", "关","郝","孔","向", "龚","邵","钱","武", "扬","黎","汤","戴",
     
118.                             "严","文","常","牛", "莫","洪","米","康", "温","代","赖","施"};
     
119.     public static final String[] lastName={"振","旦","云","祥","哲","欣","华","彦","淇","华","梓","刚","洋","煜","霖","键"
     
120.                             "利","培","欣","宇","俊","泊","政","文","杰","海","泽","泊","鑫","晖","子","硕","霖","鑫","培",
     
121.                             "智","生","明","鑫","子","哲","键","强","刚","键","子","杰","杰","成","铠","兰","霖","霖","灏"
     
122.                             "泉","泉","新","锋","瑞","翔","纯","鸿","益","睿","厚","晖","超","曦","智","博","智","杰","彦",
     
123.                             "翔","轩","泉","文","慧","瑞","祺","君","明","思","煜","铠","欣","梓","智","嵘","欣","洁","程",
     
124.                             "昌","咏","明","宝","祺","函","龙","宇","明","存","政","奕","梓","鑫","柔","方","霖","朕","嵘",
     
125.                             "松","鑫","咏","欣","睿","铭","海","霖","彦","泽","霖","宇","翌","子","政","明","佳","铠","明",
     
126.                             "富","明","柔","程","彦","汪","英","鑫","祺","宇","杰","汪","刚","金","桂","晏","嵘","宝","正",
     
127.                             "子","超","梓","洋","欣","晖","凯","兰","洋","文","霖","继","昌","君","彤","欣","华","奕","圩"
     
128.                             "文","晏","君","泽","柔","利","函","文","星","正","功","茂","雪","明","成","松","瑞","厚","宇",
     
129.                             "杰","泽","晔","嘉","泽","阳","俊","堇","存","铭","思","宇","杰","希","鑫","键","明","希","韬",
     
130.                             "欣","智","思","鑫","阳","鑫","彦","华","铠","豪","成","明","文","旻","嘉","旻","政","新","泰",
     
131.                             "存","荣","益","金","锋","鑫","俊","振","永","滨","君","智","博","杰","晔","子","文","瑞","晖",
     
132.                             "振","君","程","祺","炎","睿","政","晔","锦","佳","宇"};
     
133.     public static String getName(){
     
134.         String name=firstName[(int)(Math.random()*112)]+lastName[(int)(Math.random()*lastName.length)];
     
135.         if((int)(Math.random()*2)==0)
     
136.             name+=lastName[(int)(Math.random()*lastName.length)];
     
137.         if((int)(Math.random()*20)==5)
     
138.             name+=lastName[(int)(Math.random()*lastName.length)];
     
139.         return name;
     
140.     }
     
141.     public static String getSex(){
     
142.         if((int)(Math.random()*2)==1)
     
143.             return "男";
     
144.         else
     
145.             return "女";
     
146.     }
     
147.     public static String getCellphoneNumber(){
     
148.         String[] firstNumber={"134","135"," 136","137","138","139","150","151","152","157","158","159","187","188",//移到
     
149.             "130","131","132","155","156","185","186",//联通
     
150.             "133","153","180","189"};//电信
     
151.         return firstNumber[(int)(Math.random()*firstNumber.length)]+(int)(Math.random()*9000+1000)+(int)(Math.random()*9000+1000);
     
152.     }
     
153. }
     
154. class Producer
     
155. {
     
156.     private final Resource r;
     
157.     private boolean flag;
     
158.     private final String name;
     
159.     private Thread t;
     
160.     Producer(String name,Resource r){
     
161.         this.name=name;
     
162.         this.r=r;
     
163.     }
     
164. 
     
165.     public void work(){
     
166.         flag=true;
     
167.         t=new Thread(name){
     
168.             public void run(){
     
169.                 while(flag){
     
170.                     try{
     
171.                         r.produce();
     
172.                     }catch (InterruptedException e){
     
173.                         System.out.println(Thread.currentThread().getName()+":发生中断异常");
     
174.                     }
     
175.                 }
     
176.                 System.out.println(Thread.currentThread().getName()+":我休息1秒钟");
     
177.                 System.out.println("-----------------------------------------------------");
     
178.             }
     
179.         };
     
180.         t.setPriority(Thread.MIN_PRIORITY);
     
181.         t.start();
     
182.     }
     
183.     public void over(){
     
184.         flag=false;
     
185.         t.interrupt();
     
186.     }
     
187. }
     
188. class Consumer implements Runnable
     
189. {
     
190.     private final Resource r;
     
191.     Consumer(Resource r){
     
192.         this.r=r;
     
193.     }
     
194.     public void run(){
     
195.         while(true){
     
196.             try{
     
197.                 r.consume();
     
198.             }catch (InterruptedException e){
     
199.                 e.toString();
     
200.             }
     
201.         }
     
202.     }
     
203. }

复制代码

哇楼主列害啊，佩服佩服

希望你学完了课程还能记得这么清楚