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 stub
		FoodCache 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 block
				e.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 block
				e.printStackTrace();
			}
		}
		this.notify();
		cache[++top] =  food;
	}
	
}