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

最新推荐文章于 2025-03-12 17:00:00 发布

原创最新推荐文章于 2025-03-12 17:00:00 发布

· 2k 阅读

1 ·

版权

Java 专栏收录该内容

290 篇文章

订阅专栏

本文通过Java代码实现了一个简单的生产者消费者模型。该模型利用synchronized关键字和wait/notify机制来确保线程间的同步，避免资源竞争。生产者将数据放入队列，而消费者从队列中取出数据。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

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());
			}
		}
	}
}