生产者消费者模式

huili***

package com.umbrella.container.producerConsumer;import java.util.LinkedList;import java.util.concurrent.TimeUnit;public class ProcuderConsumer { private final LinkedList list = new LinkedList(); private final long MAX = 10; private int count = 0; public synchronized void put(T t) { while (list.size() == MAX) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } list.add(t); ++count; //不能使用notify，否则可能叫醒的是一个消费者，若此时容器中没有元素，那么消费者就会一直等一直等。 this.notifyAll(); } public synchronized T get() { T t = null; while (list.size() == 0) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } t = list.removeFirst(); count--; this.notifyAll(); return t; } public static void main(String[] args) { ProcuderConsumer pc = new ProcuderConsumer(); //启动消费者进程 for (int i = 0; i < 10; i++) { new Thread(() -> { for (int j = 0; j < 5; j++) { System.out.println(pc.get()); } }, "consumer " + i).start(); } try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); } //启动生产者进程 for (int i = 0; i < 5; i++) { new Thread(() -> { for (int j = 0; j < 10; j++) { pc.put(Thread.currentThread().getName() + " " + j); System.out.println("produce " + j); } }, "producer " + i).start(); } }}这个代码哪里写错了啊我记得生产者消费者模式是一直运行下去不会停的但我写的这个很快就结束了

已有账号？

找人解决需求

生产者消费者模式

热门问答

huili***

今日需求悬赏

今日问答求助

发布任务需求已有1031167位用户正在使用天盟网服务

新手帮助

平台规则

关于天盟

一键快捷导航

微信公众号

手机客户端