黑马程序员技术交流社区

标题: 生产者和消费者问题 [打印本页]
作者: java—family    时间: 2014-8-6 01:29
标题: 生产者和消费者问题
  1. 想搞个停止生产，和消费的方法，      不知道从那下手，百度也没出来，会的提示一下。
复制代码


作者: java—family    时间: 2014-8-6 01:32
  1. package prouderComsumer;

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

  7. //多线程间通信问题               <生产烤鸭问题>
  8. /*resoures  producer consumer  和主函数创建线程4个类。resoures定义生产和消费的方法，producer和consumer定义接受resoures的构造函数
  9. * ，并实现多线程。*/
  10. public class ProuderComsumerDemo {
  11.                         public static void main(String[] args) {
  12.                                 resoures r = new resoures();
  13.                                 producer pro = new producer(r);
  14.                                 consumer con =new consumer(r);
  15.                                 Thread t1 = new Thread(pro);
  16.                                 Thread t2 = new Thread(pro);
  17.                                 Thread t3 = new Thread(con);
  18.                                 Thread t4 = new Thread(con);
  19.                                 t1.start();
  20.                                 t2.start();
  21.                                 t3.start();
  22.                             t4.start();
  23. }
  24. }
  25. //资源
  26.   class resoures {
  27.           //定义变量：生产什么。生产多少了，生产与消费之间的切换变量
  28.           private String name;
  29.           private  int count=0;
  30.           private  boolean falg =false;
  31.           //生产方法
  32.        
  33.           public synchronized void set(String name){
  34.                   // 什么时候生产
  35.                
  36.                   while(falg)
  37.                         try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}//睡觉
  38.                    //生产      
  39.                      count++;
  40.                   if(count==1000){
  41.                          
  42.                   }
  43.                   this.name = name+count;
  44.                   System.out.println(Thread.currentThread().getName()+"生 产 了"+this.name);
  45.                   //生产完了要告诉消费者
  46.                   falg=true;
  47.                   notifyAll();
  48.                  
  49.          
  50.           }
  51.          //消费方法
  52.           public synchronized void out(){
  53.                       while(!falg)
  54.                                 try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}
  55.                      
  56.                     System.out.println(Thread.currentThread().getName()+"消 费 了"+this.name);
  57.                     falg=false;
  58.                           notifyAll();
  59.           }
  60.   }
  61. //生产者
  62. class producer implements Runnable{
  63.          private resoures r;
  64.          
  65.         public producer(resoures r) {
  66.                         super();
  67.                         this.r = r;
  68.                 }

  70.         @Override
  71.         public void run() {
  72.                    while(true){
  73.                            r.set("烤鸭");
  74.                           
  75.                    }
  76.                
  77.         }
  78.        
  79. }
  80. //消费者
  81. class consumer implements Runnable{
  82.     private resoures r;
  83.    
  84. public consumer(resoures r) {
  85.                 super();
  86.                 this.r = r;
  87.         }

  89. @Override
  90. public void run() {
  91.            while(true){
  92.                    r.out();
  93.                   
  94.                           
  95.                   
  96.            }
  97.        
  98. }

  100. }
复制代码

上面的问题怎么没代码  ，郁闷。。。。。



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