黑马程序员技术交流社区

标题: 关于这个单生产单消费的问题,不用同步,用锁机制如何完成 [打印本页]
作者: dsh    时间: 2014-10-11 21:00
标题: 关于这个单生产单消费的问题,不用同步,用锁机制如何完成
  1. package Thread_02_Produce_Consume;

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

  6. public class Phone {

  8.         //定义手机属性
  9.         String brand;
  10.         String color;
  11.         boolean flag = false;
  12.         //Lock ck = new ReentrantLock();
  13.         public Phone() {
  14.                 super();
  15.         }
  16.         //生产手机应该是手机的功能
  17.         public synchronized void setPhone(String brand,String color ) {
  18.                         //ck.lock();
  19.                         //如果有手機,就等待
  20.                         if(flag){
  21.                                 try {
  22.                                         wait();
  23.                                 } catch (InterruptedException e) {
  24.                                        
  25.                                         e.printStackTrace();
  26.                                 }
  27.                         }
  28.                         //生产手机
  29.                         this.brand=brand;
  30.                         this.color= color;
  31.                         System.out.println(Thread.currentThread().getName()+"生产手机"+brand+"..."+color);
  32.                         //生产完后,更新手机的状态
  33.                         flag= true;
  34.                         //唤醒消费者
  35.                         notify();
  36.         }
  37.                
  38.                

  40.         //消费手机应该是手机的功能
  41.         public synchronized void getPhone() {
  42.                
  43.                         if(!flag){                       
  44.                                 try {
  45.                                         wait();
  46.                                 } catch (InterruptedException e) {                                               
  47.                                         e.printStackTrace();
  48.                                 }
  49.                         }
  50.                         System.out.println(Thread.currentThread().getName()+"消费手机"+brand+"..."+color);       
  51.                         //更新手机的状态
  52.                         flag=false;
  53.                         //唤醒生产者
  54.                         notify();
  55.         }
  56.        
  57. }
复制代码

  1. package Thread_02_Produce_Consume;

  3. public class Consume_Phone implements Runnable {

  5.         Phone p;
  6.        
  7.         public Consume_Phone(Phone p) {
  8.                 this.p = p;
  9.         }
  10.         @Override
  11.         public void run() {

  13.                 while (true) {       
  14.                         p.getPhone();
  15.                 }

  17.         }
  18.        

  20. }
复制代码

  1. package Thread_02_Produce_Consume;
  2. /**
  3. * 需求:单生产单消费
  4. *
  5. * 分析:        生产者类
  6. *                         setPhone();
  7. *                   消费者类
  8. *                         getPhone();
  9. *                  手机类
  10. *                         手机提供者
  11. *                 测试类
  12. *
  13. *
  14. */
  15. public class Produce_Consume {
  16.         public static void main(String[] args) {
  17.                 //创建共享数据源
  18.                 Phone p = new Phone();
  19.                 //创建生产对象
  20.                 Produce_Phone pp = new Produce_Phone(p);
  21.                 //创建消费者对对象
  22.                 Consume_Phone cp = new Consume_Phone(p);

  24.                 //创建线程
  25.                 Thread t1 =new Thread(pp);
  26.                 Thread t2 =new Thread(cp);
  27.                
  28.                 //开启线程
  29.                 t1.start();
  30.                 t2.start();
  31.        
  32.                
  33.         }
  34. }
复制代码

  1. package Thread_02_Produce_Consume;

  3. public class Produce_Phone implements Runnable{
  4.         private Phone p;
  5.         private int num =0;

  7.         public Produce_Phone(Phone p) {
  8.                 this.p = p;
  9.         }
  10.         @Override
  11.         public void run() {
  12.                 while(true){
  13.                         if(num%2==0){
  14.                                 p.setPhone("IPhone", "土豪金");
  15.                         }else{
  16.                                 p.setPhone("小米4", "白色");
  17.                                
  18.                         }
  19.                         num++;
  20.                        
  21.                 }
  22.         }
  23. }
复制代码


作者: hollywood2014    时间: 2014-10-11 21:38
你写的是对的吧我的建议是

public void produce()
{
    lock.lock();
    try
         {
              if(不满足)
                      ...wait();//此时该线程仍然持有锁
              //满足
               生产手机
               将标志取反
               notifyall或者指定某一个与锁绑定的条件唤醒
         }
     catch(InterruptException e)//     wait()可能会有该异常,若不处理，线程便会被中断
      {
          do something
       }
      finally
       {
         lock.unlock();
       }     
}

我也是正在学习这一块，有什么不对的地方还望指正




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