使用阻塞缓冲区的生产者消费者
Repository
?
重点在于Repertory类的实现，该类提供阻塞的addProduct和getProduct，来达到生产者与消费者之间的协调。
?
public class Repertory {private int product = 0;public synchronized void addProduct() {if(this.product >= 5) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}else {product++;System.out.println("Producer produce the " + product + "production");this.notifyAll();}}public synchronized void getProduct() {if(this.product <= 0) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}else {System.out.println("Consumer takes the " + product + "production");product--;this.notifyAll();}}}?
?
Producer和Consumer
?
拥有Repository的一个实例。不需要考虑同步的问题。
?
public class Producer implements Runnable {private Repertory repertory;public Producer(Repertory repertory) {this.repertory = repertory;}public void run() {System.out.println("Producer begins to produce");while(true) {try {Thread.sleep((int) (Math.random() * 10) * 100);} catch (InterruptedException e) {e.printStackTrace();}repertory.addProduct();}}}public class Consumer implements Runnable {private Repertory repertory;public Consumer(Repertory repertory) {this.repertory = repertory;}public void run() {System.out.println("Consumer begin to take");while(true) {try {Thread.sleep((int) (Math.random() * 10) * 100);} catch(InterruptedException e) {e.printStackTrace();}repertory.getProduct();}}}?
?
ProductTest
?
产生两个线程用于生产者和消费者。
?
public class ProductTest {public static void main(String[] args) {Repertory repertory = new Repertory();new Thread(new Producer(repertory)).start();new Thread(new Consumer(repertory)).start();}}