Java线程同步：生产者-消费者 模型（代码示例）
分类：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());}}}}
上一篇Java同步机制：synchronized，wait，notify
顶0踩0
，人生不能缺乏的是雨夜－－淅沥地，独自的雨夜。这样的雨夜里，
