线程演示生产者和消费者的一个例子

生产者：向仓库容器container中填充对象，直到达到设置的库存上限MAX，然后就wait等待，并且通知叫醒notify消费者去消费。

生产者代码：

Code:

import java.util.List;
public class Product implements Runnable {
private List container = null;
private int count;
public Product(List lst) {
this.container = lst;
}
public void run() {
while (true) {
synchronized (container) {
if (container.size() > MultiThread.MAX) {
try {
container.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
container.add(new Object());
container.notify();
System.out.println("我生产了" + (++count) + "个");
}
}
}
}

消费者：消费仓库container中的货物，当库存为空等于0时就停止等待wait并且通知叫醒notify生产者。

消费者代码：

Code:

import java.util.List;
public class Consume implements Runnable {
private List container = null;
private int count;
public Consume(List lst) {
this.container = lst;
}
public void run() {
while (true) {
synchronized (container) {
if (container.size() == 0) {
try {
container.wait();// 放弃锁
} catch (InterruptedException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
container.remove(0);
container.notify();
System.out.println("我吃了" + (++count) + "个");
}
}
}
}

运行演示：启动了一个生产者和一个消费者，可以从控制台看到生产和消费的情况。

代码：

Code:

import java.util.ArrayList;
import java.util.List;
public class MultiThread {
private List container = new ArrayList();
public final static int MAX = 5;
public static void main(String args[]) {
MultiThread m = new MultiThread();
new Thread(new Consume(m.getContainer())).start();
new Thread(new Product(m.getContainer())).start();
}
public List getContainer() {
return container;
}
public void setContainer(List container) {
this.container = container;
}
}

线程演示生产者和消费者的一个例子相关推荐

【Linux下】线程同步生产者与消费者模型
文章目录 [Linux下] 线程同步生产者与消费者模型线程同步同步概念与竞态条件条件变量条件变量本质操作条件变量初始化和销毁条件变量等待唤醒通过条件变量实现的简单线程同步例子为什 ...
Windows线程（生产者与消费者问题）
Windows线程(生产者与消费者问题) 转载佟强 2008.10.10 生产者-消费者问题是一个经典的进程同步问题,该问题最早由Dijkstra提出,用以演示他提出的信号量机制.在同一个进程地址空 ...
java线程之生产者与消费者
预习java线程的三种创建方式 package com.bj.thread;import java.util.concurrent.*;/*** @FileName: TestThread* @Rem ...
JAVA笔记14__多线程共享数据（同步）/ 线程死锁 / 生产者与消费者应用案例 / 线程池...
/*** 多线程共享数据* 线程同步:多个线程在同一个时间段只能有一个线程执行其指定代码,其他线程要等待此线程完成之后才可以继续执行.* 多线程共享数据的安全问题,使用同步解决.* 线程同步两种方法: ...
java线程-从生产者和消费者模型说起
今天学习了经典的生产者和消费者模型,引起了对java线程等知识的一系列的思考. 在平时的编程中,经常遇到一个线程要产生数据,而另一个线程要处理产生出来的数据,这其实就是生产者和消费者的关系.生产者在产 ...
java-多线程(二)-生产者与消费者
什么是生产者消费者模型? 举个例子:以DOTA来说,辅助进行拉野,大哥收野,辅助就是生产者,大哥就是消费者,辅助拉一波,大哥清一波.这两个配合起来,就是生产者与消费者但是这样效率很低,毕竟一波野怪还 ...
笔记-13-多线程 Thread方法线程安全生产者和消费者死锁和阻塞
1.实现多线程 1.1简单了解多线程[理解] 是指从软件或者硬件上实现多个线程并发执行的技术. 具有多线程能力的计算机因有硬件支持而能够在同一时间执行多个线程,提升性能. 1.2并发和并行[理解] 并 ...
java的知识点34——线程通信 || 生产者与消费者问题
线程通信应用场景:生产者和消费者问题 • 假设仓库中只能存放一件产品,生产者将生产出来的产品放入仓库,消费者将仓库中产品取走消费 • 如果仓库中没有产品,则生产者将产品放入仓库,否则停止生产并等待, ...
14.4 线程通讯-生产者与消费者
package cn.chen.threadcommunication; /* 线程通讯:一个线程完成了自己的任务时,要通知另外一个线程去完成另一个任务.生产者与消费者wait(); 等待如果线程执行 ...

线程演示生产者和消费者的一个例子

线程演示生产者和消费者的一个例子相关推荐

最新文章

热门文章