Java线程同步：生产者-消费者 模型（代码示例）

public class ThreadSyn {
	
	public static void main(String[] args) {
		new ThreadSyn();
	}

	public ThreadSyn() {
		Queue queue = new Queue();

		Producter p = new Producter(queue);
		Consumer c = new Consumer(queue);

		p.start();
		c.start();
	}

	
	// Queue模拟Java线程同步中的生产者消费者仓库、队列。
	private class Queue {
		int value; // 为了使例子简单，value即为假设长度为1的仓库、队列
		boolean full = false;

		public synchronized void put(int i) {
			if (!full) {
				value = i;
				full = true;

				notify();
			}

			try {
				wait();
			} catch (InterruptedException e) {
				// e.printStackTrace();
			}
		}

		public synchronized int get() {
			if (!full)
				try {
					wait();
				} catch (InterruptedException e) {
					// e.printStackTrace();
				}

			full = false;

			notify();

			return value;
		}
	}

	
	// Java线程同步模型-生产者
	private class Producter extends Thread {
		private Queue q;

		public Producter(Queue q) {
			this.q = q;
		}

		public void run() {
			for (int i = 0; i < 20; i++) {
				System.out.println("生产了:" + i);
				q.put(i);
			}
		}
	}

	// Java线程同步模型-消费者
	private class Consumer extends Thread {
		private Queue q;

		public Consumer(Queue q) {
			this.q = q;
		}

		public void run() {
			while (true) {
				System.out.println("消费了:" + q.get());
			}
		}
	}
}