生产者

/** * 类说明：生产者 *  * @author 作者: user * @version 创建时间：2011-4-5 下午01:48:11 */public class Producer implements Runnable {	private SyncStack ss;	private int num;	private static int counter = 1;	public Producer(SyncStack ss) {		this.ss = ss;		num = counter++;	}	@Override	public void run() {		char c;		for (int i = 0; i < 10; i++) {			c = (char) (Math.random() * 26 + 'A');			ss.push(c);//向堆栈中添加数据			System.out.println("生产者 " + num + ": " + c);			try {				Thread.sleep((int) (Math.random() * 300));			} catch (InterruptedException e) {				e.printStackTrace();			}		}	}}

消费者

/** * 类说明：消费者 *  * @author 作者: user * @version 创建时间：2011-4-5 下午01:56:18 */public class Consumer implements Runnable {	private SyncStack ss;//堆栈对象	private int num;	private static int counter = 1;	public Consumer(SyncStack ss) {		this.ss = ss;		num = counter++;	}	@Override	public void run() {		char c;		for (int i = 0; i < 10; i++) {			c = ss.pop();//从堆栈中取数据			System.out.println("消费者 " + num + ": " + c);			try {				Thread.sleep((int) (Math.random() * 200));			} catch (InterruptedException e) {				e.printStackTrace();			}		}	}}

堆栈类

import java.util.ArrayList;import java.util.List;/** * 类说明：堆栈类 *  * @author 作者: user * @version 创建时间：2011-4-5 下午01:17:48 */public class SyncStack {	private List
    
      buffer = new ArrayList
     
      ();	public SyncStack() {	}	// 堆栈取数据	public synchronized char pop() {		char c;		if (buffer.size() == 0) {			try {				System.out.println(Thread.currentThread().getName()						+ " 正在等待 ……………………");				this.wait();// 如果堆栈中没有数据 则线程等待			} catch (Exception e) {				e.printStackTrace();			}		}		c = ((Character) buffer.get(buffer.size() - 1)).charValue();		buffer.remove(buffer.size() - 1);		return c;	}	// 向堆栈中添加数据	public synchronized void push(char c) {		this.notify();// 唤醒在此对象监视器上等待的单个线程		Character ch = new Character(c);		buffer.add(ch);	}}
     
    

主方法

/** * 类说明： *  * @author 作者: user * @version 创建时间：2011-4-5 下午01:59:54 */public class Main {	/**	 * @param args	 */	public static void main(String[] args) {		SyncStack ss = new SyncStack();		//生产者p		Producer p = new Producer(ss);		Thread t1 = new Thread(p);		t1.start();		//生产者p2		Producer p2 = new Producer(ss);		Thread t3 = new Thread(p2);		t3.start();		//消费者1		Consumer c = new Consumer(ss);		Thread t2 = new Thread(c);		t2.setName("消费者1 ");		t2.start();		//消费者1		Consumer c2 = new Consumer(ss);		Thread t4 = new Thread(c2);		t4.setName("消费者2 ");		t4.start();	}}