使用阻塞缓冲区的生产者消费者

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();
	}
}