java 生产者消费者示例

import java.util.Random;

/**
 * 过程介绍：
 * 1.生产者，pool满，则等待消费；
 * 2.消费者消费，pool空了，则等待生产；
 * 
 * 要点：
 * 1.在什么地方（那个类的对象上）调用wait与notify，让其线程之间协作；
 * 2.必须在协作的原子操作上，加同步；为了便于理解，直接加载了方法上，可以缩小范围；
 */
public class ProducerAndConsumer {
	private static final int sleepTime = 1000;//睡眠时间

	private static final int consumenrThreadNum = 1;//消费者线程数

	private static final int producerThreadNum = 4;//生产者线程数

	public static void main(String[] args) {
		Pool pool = new Pool();
		Consumenr c = new Consumenr(pool);
		Producer p = new Producer(pool);

		for (int i = 0; i < producerThreadNum; i++) {
			Thread producerThread = new Thread(p, " 生产[" + i + "]");
			producerThread.start();
		}
		for (int i = 0; i < consumenrThreadNum; i++) {
			Thread consumenrThread = new Thread(c, "消费[" + i + "]");
			consumenrThread.start();
		}
	}

	/**
	 * 消费者
	 * @author muyx
	 */
	static class Consumenr implements Runnable {
		private Pool pool;

		public Consumenr(Pool pool) {
			this.pool = pool;
		}

		@Override
		public void run() {
			while (true) {
				pool.get();
			}
		}
	}

	/**
	 * 生产者
	 * @author muyx
	 */
	static class Producer implements Runnable {
		private Pool pool;
		private Random r = new Random();

		public Producer(Pool pool) {
			this.pool = pool;
		}

		@Override
		public void run() {
			while (true) {
				pool.put(r.nextInt(10));
			}
		}
	}

	/**
	 * 生产消费的缓冲池
	 * @author muyx
	 */
	static class Pool {
		private int[] pools = new int[10];
		private int cpoint = 0;

		public synchronized void put(int food) {
			Thread t = Thread.currentThread();
			String name = t.getName();
			try {
				if (!isFull()) {
					pools[cpoint++] = food;
					System.out.println(name + this);
					this.notifyAll();
					t.sleep(sleepTime);
				} else {
					System.out.println(name + " 等待中........");
					this.wait();
				}
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}

		public synchronized void get() {
			Thread t = Thread.currentThread();
			String name = t.getName();
			try {
				if (!isEmpty()) {
					pools[--cpoint] = -1;
					this.notifyAll();
					System.out.println(name + this);
					t.sleep(sleepTime);
				} else {
					System.out.println(name + " 等待中.........");
					this.wait();
				}
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}

		public boolean isFull() {
			return this.pools.length == cpoint;
		}

		public boolean isEmpty() {
			return this.cpoint == 0;
		}

		@Override
		public String toString() {
			StringBuilder sb = new StringBuilder("[");
			for (int i = 0, len = pools.length - 1; i < len; i++) {
				sb.append(pools[i] + ",");
			}
			sb.append(pools[pools.length - 1]);
			return sb.append("]").toString();
		}
	}
}

打印结果：

 生产[0][9,0,0,0,0,0,0,0,0,0]
消费[1][-1,0,0,0,0,0,0,0,0,0]
消费[1] 等待中.........
消费[0] 等待中.........
 生产[0][2,0,0,0,0,0,0,0,0,0]
 生产[0][2,2,0,0,0,0,0,0,0,0]
 生产[0][2,2,0,0,0,0,0,0,0,0]
消费[0][2,2,-1,0,0,0,0,0,0,0]
消费[0][2,-1,-1,0,0,0,0,0,0,0]
消费[0][-1,-1,-1,0,0,0,0,0,0,0]
消费[0] 等待中.........
 生产[0][8,-1,-1,0,0,0,0,0,0,0]
 生产[0][8,1,-1,0,0,0,0,0,0,0]
 生产[0][8,1,4,0,0,0,0,0,0,0]