黑马程序员技术交流社区

标题: 昨天看多线程那个生产者消费者了，分享下。哈 [打印本页]
作者: 小悟空et    时间: 2015-5-29 10:53
标题: 昨天看多线程那个生产者消费者了，分享下。哈
真是，如果不天天练就手生，写这么短的程序，写了得半个小时，哎~~

  1. import java.util.concurrent.locks.Condition;
  2. import java.util.concurrent.locks.Lock;
  3. import java.util.concurrent.locks.ReentrantLock;


  6. public class ProducerConsumerDemo
  7. {
  8.         public static void main(String[] args)
  9.         {
  10.                 Resource r = new Resource();

  12.                
  13.                 Producer p = new Producer(r);
  14.                 Consumer c = new Consumer(r);
  15.                
  16.                 Thread t1 = new Thread(p);
  17.                 Thread t2 = new Thread(p);
  18.                 Thread t3 = new Thread(c);
  19.                 Thread t4 = new Thread(c);
  20.                
  21.                 t1.start();
  22.                 t2.start();
  23.                 t3.start();
  24.                 t4.start();
  25.                
  26.                
  27.                
  28.                
  29.         }
  30.        
  31. }

  33. class Resource
  34. {
  35.         Lock lock = new ReentrantLock();
  36.         Condition proCon = lock.newCondition();
  37.         Condition conCon = lock.newCondition();
  38.         private String name;
  39.         private int count=1;
  40.         boolean flag = false;
  41.         public void set(String name) throws InterruptedException
  42.         {
  43.                 lock.lock();
  44.                 try{
  45.                 while(flag)
  46.                         proCon.await();
  47.                 this.name = name +":"+ count++;
  48.                 System.out.println(Thread.currentThread().getName()+"生产出了"+this.name);
  49.                 flag = true;
  50.                 conCon.signal();
  51.                 }
  52.                 finally
  53.                 {
  54.                         lock.unlock();
  55.                 }
  56.                
  57.         }
  58.        
  59.         public void out() throws InterruptedException
  60.         {
  61.        
  62.                 lock.lock();
  63.                 try
  64.                 {
  65.                         while(!flag)
  66.                                 conCon.await();
  67.                         System.out.println(Thread.currentThread().getName()+"消费出了。。。。。。。"+this.name);
  68.                         flag = false;
  69.                         proCon.signal();
  70.                 }
  71.                 finally
  72.                 {
  73.                         lock.unlock();
  74.                 }
  75.        
  76.         }
  77. }

  79. class Producer implements Runnable
  80. {
  81.         private Resource res;
  82.         Producer(Resource res)
  83.         {
  84.                 this.res = res;
  85.         }
  86.         public void run()
  87.         {
  88.                 while(true)
  89.                 {
  90.                         try
  91.                         {
  92.                                 res.set("商品");
  93.                         }
  94.                         catch(InterruptedException e)
  95.                         {
  96.                                
  97.                         }
  98.                 }
  99.                
  100.         }
  101. }

  103. class Consumer implements Runnable
  104. {
  105.         private Resource res;
  106.        
  107.         Consumer(Resource res)
  108.         {
  109.                 this.res = res;
  110.         }
  111.         public void run()
  112.         {
  113.                 while(true)
  114.                 {
  115.                         try
  116.                         {
  117.                                 res.out();
  118.                         }
  119.                         catch(InterruptedException e)
  120.                         {                               
  121.                         }                       
  122.                 }               
  123.         }
  124. }






复制代码







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