黑马程序员技术交流社区

标题: 自己想了一个多线程的题目（带答案），欢迎大牛来做 [打印本页]
作者: as604049322    时间: 2014-12-25 21:06
标题: 自己想了一个多线程的题目（带答案），欢迎大牛来做
本帖最后由 as604049322 于 2014-12-25 21:30 编辑

问题描述：有一个大型商场，该商场拥有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.*;

  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.     }

  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
很给力，今天晚上太晚了，没时间仔细看了，不过我下一期的技术分活动就是多线程。在我的题目中是有预告的。
作者: as604049322    时间: 2014-12-26 07:35
本帖最后由 as604049322 于 2014-12-26 10:43 编辑
王震阳老师 发表于 2014-12-26 00:29
很给力，今天晚上太晚了，没时间仔细看了，不过我下一期的技术分活动就是多线程。在我的题目中是有预告的。 ...

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

代码如下：
  1. import java.util.concurrent.locks.*;

  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.     }

  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. }
复制代码

1.png (11.83 KB, 下载次数: 18)

1.png

2.png (11.68 KB, 下载次数: 13)

2.png

1.png (11.83 KB, 下载次数: 15)

1.png

2.png (11.68 KB, 下载次数: 12)

2.png
作者: 南柯一梦境    时间: 2014-12-26 07:43
哇楼主列害啊，佩服佩服
作者: 小小志    时间: 2014-12-26 20:14
希望你学完了课程还能记得这么清楚



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