黑马程序员技术交流社区

标题: Lock和Condition [打印本页]
作者: iceknc    时间: 2015-9-21 22:24
标题: Lock和Condition
  1. import java.util.concurrent.locks.*;

  3. public class Goods {
  4.         private String name;
  5.         private int count = 0;
  6.         private boolean flag = false;
  7.         //定义一个锁
  8.         private final Lock lock = new ReentrantLock();
  9.         //定义生产者持的锁
  10.         private final Condition conditionPro = lock.newCondition();
  11.         //定义消费者持的锁
  12.         private final Condition conditionCon = lock.newCondition();
  13.        
  14.         public void in(String name) throws InterruptedException {
  15.                 lock.lock();
  16.                 try{
  17.                         while(flag)
  18.                                 conditionPro.await();
  19.                         this.name = name + "---" + count++;
  20.                         System.out.println(Thread.currentThread().getName() + " 生产 " + this.name);
  21.                         flag = true;
复制代码
  1. public class Producer implements Runnable {
  2.         private Goods g;
  3.        
  4.         public Producer(){}
  5.         public Producer(Goods g) {
  6.                 this.g = g;
  7.         }
  8.        
  9.         public void run(){
  10.                 while(true){
  11.                         try{
  12.                                 g.in("#商品#");
  13.                         }
  14.                         catch(InterruptedException e){
  15.                        
  16.                         }
  17.                 }               
  18.         }
  19. }
复制代码

  2. public class Consumer implements Runnable{
  3.         private Goods g;
  4.        
  5.         public Consumer(){}
  6.         public Consumer(Goods g) {
  7.                 this.g = g;
  8.         }
  9.        
  10.         public void run(){
  11.                 while(true){
  12.                         try{
  13.                                 g.out();
  14.                         }
  15.                         catch(InterruptedException e){
  16.                        
  17.                         }
  18.                 }       
  19.         }
  20. }
复制代码
  1. public class TestMain {

  3.         /**
  4.          * @param args
  5.          */
  6.         public static void main(String[] args) {
  7.                 // TODO Auto-generated method stub
  8.                 Goods g = new Goods();
  9.                 Producer p = new Producer(g);
  10.                 Consumer c = new Consumer(g);
  11.                
  12.                 new Thread(p).start();
  13.                 new Thread(p).start();
  14.                 new Thread(c).start();
  15.                 new Thread(c).start();
  16.         }
  17. }
复制代码

重要的代码写三遍，今天终于可以自己背着写出来了。



作者: iceknc    时间: 2015-9-21 22:26
  1. import java.util.concurrent.locks.*;

  3. public class Goods {
  4.         private String name;
  5.         private int count = 0;
  6.         private boolean flag = false;
  7.         //定义一个锁
  8.         private final Lock lock = new ReentrantLock();
  9.         //定义生存者持的锁
  10.         private final Condition conditionPro = lock.newCondition();
  11.         //定义消费者持的锁
  12.         private final Condition conditionCon = lock.newCondition();
  13.        
  14.         public void in(String name) throws InterruptedException {
  15.                 lock.lock();
  16.                 try{
  17.                         while(flag)
  18.                                 conditionPro.await();
  19.                         this.name = name + "---" + count++;
  20.                         System.out.println(Thread.currentThread().getName() + " 生产 " + this.name);
  21.                         flag = true;
  22.                         conditionCon.signal();
  23.                 }
  24.                 finally{
  25.                         lock.unlock();
  26.                 }
  27.                        
  28.         }       
  29.         public void out()throws InterruptedException {
  30.                 lock.lock();
  31.                 try{
  32.                         while(!flag)
  33.                                 conditionCon.await();
  34.                         System.out.println(Thread.currentThread().getName() + " ...消费 " + this.name);
  35.                         flag = false;
  36.                         conditionPro.signal();
  37.                 }
  38.                 finally{
  39.                         lock.unlock();
  40.                 }
  41.         }
  42. }
复制代码


复制漏了



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