线程通信-----生产者与消费者案例-白红宇

线程通信-----生产者与消费者案例

阅读量：1822 次

发布时间：2019-04-25

本文共 2267 字，大约阅读时间需要 7 分钟。

import java.util.LinkedList;public class Test {	public static void main(String[] args) {		Baskets baskets = new Baskets();		Producters producters = new Producters(baskets);		Consumers consumers = new Consumers(baskets);		producters.start();//生产者进行生产		consumers.start();//消费者进行消费	}}/** * 消费者线程 * @author Administrator * */class Consumers extends Thread{	private Baskets baskets = null;	public Consumers(Baskets baskets) {		this.baskets = baskets;	}	@Override	public void run() {		baskets.popApple();	}}/** * 生产者线程 * @author Administrator * */class Producters extends Thread{	private Baskets baskets = null;	public Producters(Baskets baskets) {		this.baskets = baskets;	}	@Override	public void run() {		baskets.pushApple();	}}class Baskets{	private LinkedList
   
     basket = new LinkedList<>();//创建一个篮子原来存放Apples	/**	 * 分四次取出苹果	 */	public synchronized void popApple() {//需要声明同步方法才能获得该对象的锁		for(int i=0;i<20;i++) {			pop();		}	}			/**	 * 分四次放苹果	 */	public synchronized void pushApple() {//需要声明同步方法才能获得该对象的锁		for(int i=0;i<20;i++) {			Apples apples = new Apples(i);			push(apples);		}	}		/**	 * 取出苹果	 * @param apples	 */	public void pop() {		if(basket.size() == 0) {//当篮子里面的苹果为0,通知并等待生产者来生产			try {				wait();//等待并释放当前该对象锁			} catch (InterruptedException e) {				e.printStackTrace();			}		}		try {			Thread.sleep(500);		} catch (InterruptedException e) {			e.printStackTrace();		}				System.out.println("取出"+basket.removeFirst().toString());		notify();//通知生产者来生产	}	/**	 * 存放苹果	 * @param apples	 */	public void push(Apples apples) {		if(basket.size() == 5) {//当篮子里面的苹果满了通知并等待消费者来消费			try {				wait();//等待并释放当前该对象锁			} catch (InterruptedException e) {				e.printStackTrace();			}		}		try {			Thread.sleep(500);		} catch (InterruptedException e) {			e.printStackTrace();		}		basket.addFirst(apples);		System.out.println("存放"+apples.toString());		notify();//通知消费者来消费	}	}class Apples{	private int id;	public Apples(int id) {//给每个苹果标号		this.id = id ;	}	public String toString() {		return "苹果"+(id+1);	}}

【运行结果】

存放苹果1

存放苹果2

存放苹果3

存放苹果4

存放苹果5

取出苹果5

取出苹果4

取出苹果3

取出苹果2

取出苹果1

存放苹果6