那什么是生产者消费者模式?
在一个生产环境中,生产者负责向缓冲区内添加商品(添加数据),消费者负责从缓冲区取出数据。
最经典的现实案例就是KFC,厨师(生产者)向存储汉堡的货柜(缓冲区)中添加汉堡(添加数据),消费者去点餐,购买汉堡(取出数据)。这就是最简单的生产者消费者模式。
1.汉堡类,所需要基本数据对象
//设置数据对象的基本属性,这里使用最简单的id
public class Hamburger {
//设置商品的属性
private Integer id;
public Hamburger(Integer id) {
this.id = id;
}
@Override
public String toString() {
return "Hamburger{" +
"id=" + id +
'}';
}
}
2.制作装汉堡的容器,缓冲区存放生产者生产的数据对象
//创建容器
public class Container {
//定义一个数组来装汉堡
//当然这里也可以用集合框架ArrayList<Hamburger>来进行存储数据
public Hamburger[] array = new Hamburger[6];
public int index = 0;
//对每次操作添加锁,避免多个线程操作同一个资源
//也可以使用重入锁ReentrantLock
/*
*ReentrantLock使用方法:
1.创建ReentrantLock对象
private ReentrantLock reentrantLock = new ReentrantLock();
2.加锁:
reentrantLock.lock();
3.解锁:
reentrantLock.unlock();
*两个方法间就是锁住的内容,资源
*/
//向容器中添加汉堡
public synchronized void push(Hamburger hamburger){
if(index < array.length){
array[index] = hamburger;
index++;
System.out.println("生产了一个汉堡:" + hamburger);
}
}
//从容器中取出汉堡
public synchronized Hamburger pop(){
if(index>0){
index--;
System.out.println("消费了一个汉堡:" + array[index]);
return array[index];
}
return null;
}
}
3.创建生产者线程:
//生产者
public class Producer implements Runnable {
//创建容器对象
private Container container = null;
public Producer(Container container) {
this.container = container;
}
@Override
public void run() {
for (int i = 0; i < 30; i++) {
//创建带编号的汉堡对象
Hamburger hamburger = new Hamburger(i);
//将汉堡装入容器中
this.container.push(hamburger);
try {
//线程休眠
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
4.创建消费者线程
public class Consumer implements Runnable {
//创建容器对象
private Container container = null;
public Consumer(Container container) {
this.container = container;
}
@Override
public void run() {
for (int i = 0; i < 30; i++) {
//购买汉堡
this.container.pop();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
5.测试类
public class Test {
public static void main(String[] args) {
//创建生产者,消费者,容器对象
Container container = new Container();
Producer producer = new Producer(container);
Consumer consumer = new Consumer(container);
//开启生产者,消费者线程
new Thread(producer).start();
new Thread(producer).start();
new Thread(consumer).start();
new Thread(consumer).start();
new Thread(consumer).start();
}
}
文章浏览阅读2.1k次。一、startActivity启动过程启动流程:点击桌面App图标,Launcher进程采用Binder IPC向system_server进程发起startActivity请求;system_server进程接收到请求后,向zygote进程发送创建进程的请求;Zygote进程fork出新的子进程,即App进程;App进程,通过Binder IPC向sytem_server进程发起a..._startactivity
文章浏览阅读3.2k次。零基础想要学习编程,第一步首先决定要学哪一门语言,了解它们的特点和应用的领域;第二步确定学习方法,自学还要结合一些辅助资料或工具;第三步,调整良好的心理状态,为学习编程创建一个稳定的心理环境。_零基础自学编程
文章浏览阅读895次,点赞17次,收藏14次。在很多情况下,很多人想到的测试方法是穷举测试,穷举测试是最全面的测试,但是数据量很大的情况下不太现实,测试效率太低,后来为了减少测试人员的工作量和提高测试的效率和以达到最好的测试质量,慢慢的就有了等价类的测试方法。1)划分等价类 一, 应按照输入条件(如输入值的范围,值的个数,值的类型,输入的条件如何等),划分有效输入和无效输入(有效等价类和无效等价类) ,总的来说,需求以内的都属于有效输入,需求以外的都属于无效输入。则需要测试的边界值为:1个字符,2个字符,3个字符,8个字符,9个字符,10个字符。_等价类适用于什么场景
文章浏览阅读399次。目录一、C语言调用汇编函数二、将原汇编语言 Init_1函数的类型改为 int Init_1(init) ,此函数功能修改为 传入一个整型数x,函数运行后返回整型数 x+100三、在汇编函数中调用一个 C语言写的函数四、总结五、参考链接:MDK下C与汇编语言混合编程 - the7一、C语言调用汇编函数 1.打开keil 5新建工程 2.右击Source Group1 添加新项目3.点击 Asm File(.s) ,输入na..._stm32 c语言可以嵌入汇编语言
文章浏览阅读179次。纯手写LinkeList集合LinkeList原理LinkedList 和 ArrayList 一样,都实现了 List 接口,但其内部的数据结构有本质的不同。LinkedList 是基于链表实现的(通过名字也能区分开来),所以它的插入和删除操作比 ArrayList 更加高效。但也是由于其为基于链表的,所以随机访问的效率要比 ArrayList 差。LinkedList数据结构原理Lin..._手写集合
文章浏览阅读918次。规定通过mqtt_user表格验证过的用户才能连接EMQ服务器,我们需要开启mysql插件认证。EMQ2.0自带mysql插件,下面开始配置。新建mqtt_user表格要想控制用户登录EMQ,肯定是首先创建一个可管理的用户表格,规定只有在这个表格中的用户才能被允许连接EMQ。 按照EMQ官方文档在你mysql服务器中新建一个mqtt_user的表格(http://www.emqtt.com/doc..._emqx中mysql插件启动出现parse_config_file_failed
文章浏览阅读1.8k次,点赞16次,收藏27次。使用下载的镜像,启动容器,使用modelscope命令下载。模型:Qwen1.5-Qwen-7B-Chat。镜像:qwenllm/qwen:cu121。【新手入门,多有遗漏,私信交流】文件后缀改为 .py 文件。3、安装langchain。_qwen1.5 部署
文章浏览阅读4.3k次,点赞4次,收藏37次。为了解决蝴蝶优化算法(BOA)精度低、收敛速度慢的问题,研究的趋势是将两种或两种以上的算法混合,以获得优化问题的最优解。提出了一种新的混合算法HPSOBOA,并介绍了三种改进基本BOA的方法。因此,引入了利用Cubi映射对BOA进行初始化,并采用非线性参数控制策略。此外,将粒子群优化(PSO)算法与BOA算法相结合,改进了基本的BOA算法,使其能够进行全局优化。函数测试实验验证了该算法的有效性。实验结果表明,与GWO、BOA等算法相比,混合HPSOBOA算法收敛速度快,在高维数值优化问题中具有更好的稳定性。_cubic混沌映射
文章浏览阅读76次。如何安装Cacti,见前文Hyper-v下安装网络流量监测图形分析工具 Cacti 在Windows Server 2008以后的版本中,SNMP是以一个功能的形式存在的,不像Windows Server 2003里中是以Windows组件的形式存在的,所以安装的方法也不一样。您可以参照下面的步骤来安装SNMP服务。 1 打开服务器管理器,点击功能节点,点击..._网络流量分析工具 winserver2008r2
文章浏览阅读509次。机器翻译工具通过NLP自然语言处理将一种语言翻译成另一种语言,机器翻译随着科技进步已经不仅仅局限于文字翻译,现在我们可以通过语音进行翻译还可以与机器人进行料体聊天。这些都是机器翻译的应用。..._机器翻译输出指定样式怎么设置
文章浏览阅读1.2k次,点赞41次,收藏15次。DevExpress(Developer Express Inc.)是一家知名的软件开发公司,提供一系列用于.NET框架的软件开发工具和组件,特别是针对桌面、网页以及移动平台的应用开发。DevExpress的产品有助于开发人员构建复杂的用户界面、提升应用程序的性能和可用性,以及提高开发效率。:用于构建Windows窗体应用程序的一套丰富的用户界面控件。:提供用于Windows Presentation Foundation(WPF)应用程序的高性能用户界面组件。_devexpress是什么软件
文章浏览阅读1.2k次。mysql有以下几种日志:错误日志: -log-err查询日志: -log慢查询日志: -log-slow-queries更新日志: -log-update二进制日志:-log-bin日志文件文件中的信息作用错误日志记录启动、运行或停止mysqld时出现的问题。系统故障时定位故障原因查询日志记录建立的客户端连接和执行的语句。记录数据库发生的所有操作二进制日志记录所有更改数据的语句。数据库..._如何查看 mysql 重启次数