黑马程序员技术交流社区

标题: Condition到底是什么 [打印本页]
作者: 黄连兵    时间: 2012-6-12 09:20
标题: Condition到底是什么
本帖最后由 黄连兵 于 2012-6-12 09:57 编辑

毕老师的视频教程多线程中有一个经典例子，使用Lock+Condition来替代Synchronize。
其中的Condition_p 和 Condition_c 是如何跟线程绑定的？使得lock可以把当前线程分成两种情况来管理？
例子中两个生产线程t1，t2,两个消费线程t3 , t4并没有显式地与Condition_p 和 Condition_c绑定，
我们只知道Condition_p结束后会唤醒Condition_c，Condition_c结束后会唤醒Condition_p.

个人的理解是，两类线程通过程序的入口来实现的绑定，Producer的入口是set(),进去后就是Condition_p，而Consumer的入口是out(),进去后就是Condition_c，
  1. <p>package com.practise;
  2. import java.util.concurrent.locks.*;
  3. </p><p>
  4. public class Lock {
  5. </p><p> /**
  6.   * @param args
  7.   */
  8. public static void main(String[] args) {
  9.   // TODO Auto-generated method stub</p><p>  Resource res=new Resource();
  10.   Thread pro1=new Thread(new Producer(res));
  11.   Thread pro2=new Thread(new Producer(res));
  12.   
  13.   Thread con1=new Thread(new Consumer(res));
  14.   Thread con2=new Thread(new Consumer(res));
  15.   pro1.start();
  16.   pro2.start();
  17.   con1.start();
  18.   con2.start();
  19.   }
  20. }
  21. </p><p>
  22. class Resource{
  23. private String name;
  24. private int count=1;
  25. private boolean flag=false;

  27. private ReentrantLock lock=new ReentrantLock();
  28. //此处为什么我写成private Lock lock=new ReentrantLock();会报错,这个向上转型有问题么？毕老师的是正常的~！难道又是版本问题？
  29. </p><p>
  30. private Condition condition_p=lock.newCondition();
  31. private Condition condition_c=lock.newCondition();

  33. public void set(String name)throws InterruptedException{
  34.   lock.lock();
  35.   try{
  36.   while(flag)
  37.    condition_p.await();
  38.   this.name=name+"..."+count++;
  39.   System.out.println(Thread.currentThread().toString()+"...producer..."+this.name);
  40.   flag=true;
  41.   condition_c.signal();
  42. }
  43.   finally{
  44.    lock.unlock();
  45.   }
  46. }
  47. public void out()throws InterruptedException{
  48.   lock.lock();
  49.   try{
  50.    while(!flag)
  51.     condition_c.await();
  52.    System.out.println(Thread.currentThread().toString()+"......consumer......"+this.name);
  53.    flag=false;
  54.    condition_p.signal();
  55.   }
  56.   finally{
  57.    lock.unlock();
  58.   }
  59. }
  60. }</p><p>class Producer implements Runnable{
  61. private Resource res;
  62. Producer(Resource res)
  63. {
  64.   this.res=res;
  65. }
  66. public void run(){
  67.   while(true)
  68.    try {
  69.     res.set("商品");
  70.    } catch (InterruptedException e) {
  71.     // TODO Auto-generated catch block
  72.     e.printStackTrace();
  73.    }  
  74. }
  75. }</p><p>class Consumer implements Runnable{
  76. private Resource res;
  77. Consumer(Resource res)
  78. {
  79.   this.res=res;
  80. }
  81. public void run(){
  82.   while(true)
  83.    try {
  84.     res.out();
  85.    } catch (InterruptedException e) {
  86.     // TODO Auto-generated catch block
  87.     e.printStackTrace();
  88.    }  
  89. }
  90. }</p><p> </p>
复制代码
作者: 黄连兵    时间: 2012-6-12 09:54
多谢版主鼓励，总算长分了呀~!{:soso_e109:}
作者: 孙浩迪    时间: 2012-6-12 13:18
我就这么写的，没问题的，  是不是你没导包？？  你看下



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