Java 多线程例子 线程同步互斥操作 生产者消费者进程
?
Food类：食物 ，代表缓存里面的产品
FoodCache：缓存，用栈实现
Producer：生产者进程
Consumer：消费者进程
Demo：例子
?
?
?
?
?
?
?
?
?
?
/* * @(#)Food.java, 2012-10-18 上午09:49:26 * * All rights reserved. */package com.wang.thread;/** * 在这里加入功能说明 * * @author wangxiaowei * @version $Revision: 1.4 $, 2012-10-18$ */public class Food{private int id;public Food(int id){this.id = id;}/** * @return Returns the id. */public int getId(){return id;}/** * @param id The id to set. */public void setId(int id){this.id = id;}}/** @(#)FoodCache.java, 2012-10-18 上午09:51:24 * * All rights reserved. */package com.wang.thread;/** * 在这里加入功能说明 * * @author wangxiaowei * @version $Revision: 1.4 $, 2012-10-18$/** @(#)Consumer.java, 2012-10-18 上午10:13:53 * * All rights reserved. */package com.wang.thread;/** * 在这里加入功能说明 * * @author wangxiaowei * @version $Revision: 1.4 $, 2012-10-18$ */public class Consumer extends Thread{ private FoodCache foodCache; public Consumer(FoodCache foodCache) { this.foodCache = foodCache; } public void run() { for(int i=0; i<10; i++) { synchronized(foodCache) { Food food = foodCache.pop(); System.out.println("消费了："+food.getId()+"号食物!"); } } }}?/** @(#)Producer.java, 2012-10-18 上午10:08:42 * * All rights reserved. */package com.wang.thread;/** * 在这里加入功能说明 * * @author wangxiaowei * @version $Revision: 1.4 $, 2012-10-18$ */public class Producer extends Thread{ private FoodCache foodCache; public Producer(FoodCache foodCache) { this.foodCache = foodCache; } public void run() { for(int i=0; i<10; i++) { synchronized(foodCache) { Food food = new Food(i); System.out.println("生产了第"+food.getId()+"号食物"); foodCache.push(food); } } } }?/** @(#)Demo.java, 2012-10-18 上午10:15:53 * * All rights reserved. */package com.wang.thread;/** * 在这里加入功能说明 * * @author wangxiaowei * @version $Revision: 1.4 $, 2012-10-18$ */public class Demo{/** * */public static void main(String[] args){// TODO Auto-generated method stubFoodCache foodCache = new FoodCache();Producer producer = new Producer(foodCache);Consumer consumer = new Consumer(foodCache);producer.start();consumer.start();}}? */public class FoodCache{private int length = 10 ;private Food[] cache = new Food[length];private int top = -1;public FoodCache(){}public Food pop(){while(top==-1){try{System.out.println("缓存没有食物了，我的心在等待 .........");this.wait();}catch (InterruptedException e){// TODO Auto-generated catch blocke.printStackTrace();}}this.notify();return cache[top--];}public void push(Food food){while(top==length-1){try{this.wait();System.out.println("缓存里面的食物已经满了，快来吃我吧！");}catch (InterruptedException e){// TODO Auto-generated catch blocke.printStackTrace();}}this.notify();cache[++top] = food;}}