Java基于Lock的生产者消费者模型示例

package com.expgiga.juc;

import java.util.concurrent.locks.condition;

import java.util.concurrent.locks.lock;

import java.util.concurrent.locks.reentrantlock;

/**

  * 生产者消费者案例

  */

public class testproductorandconsumerforlock {

   public static void main(string[] args) {

     clerk clerk = new clerk();

     productor productor = new productor(clerk);

     consumer consumer = new consumer(clerk);

     new thread(productor, "生产者a" ).start();

     new thread(consumer, "消费者b" ).start();

     new thread(productor, "生产者c" ).start();

     new thread(consumer, "消费者d" ).start();

   }

}

//店员

class clerk {

   private int product = 0 ;

   private lock lock = new reentrantlock();

   private condition condition = lock.newcondition();

   //进货方法

   public void get() {

     lock.lock();

     try {

       while (product >= 1 ) { //为了避免虚假唤醒，应该总是使用在循环中

         system.out.println( "产品已满！" );

         try {

           condition.await();

         } catch (interruptedexception e) {

           e.printstacktrace();

         }

       }

       system.out.println(thread.currentthread().getname() + " : " + ++product);

       condition.signalall();

     } finally {

       lock.unlock();

     }

   }

   //卖货方法

   public void sale() {

     lock.lock();

     try {

       while (product <= 0 ) {

         system.out.println( "产品缺货！" );

         try {

           condition.await();

         } catch (interruptedexception e) {

           e.printstacktrace();

         }

       }

       system.out.println(thread.currentthread().getname() + " : " + --product);

       condition.signalall();

     } finally {

       lock.unlock();

     }

   }

}

//生产者

class productor implements runnable {

   private clerk clerk;

   public productor(clerk clerk) {

     this .clerk = clerk;

   }

   @override

   public void run() {

     for ( int i = 0 ; i < 20 ; i++) {

       try {

         thread.sleep( 200 );

       } catch (interruptedexception e) {

         e.printstacktrace();

       }

       clerk.get();

     }

   }

}

//消费者

class consumer implements runnable {

   private clerk clerk;

   public consumer(clerk clerk) {

     this .clerk = clerk;

   }

   @override

   public void run() {

     for ( int i = 0 ; i < 20 ; i++) {

       clerk.sale();

     }

   }

}