Java中高级高并发与多线程系列(六):经典的生产者-消费者模型
首先声明,本系列文章分享都是我自己的学习理解以后,原创手敲,可能包含错误的观点和理解,仅供参考,如遇错误的地方欢迎指正。
上一篇我们学会了 synchronized 线程同步,到这里已经可以做一些东西了,最为经典的就是生产者-消费者模型,一个生产者不停的生产资源,一个消费者不停的消费资源,两个线程模拟这样的关系,好比厨师和传菜工,厨师不停的炒菜,传菜工看到有菜了就端走。
多线程系列全部演示代码公开在:https://github.com/renfei/demo/tree/master/java/ConcurrentDemo
生产者与消费者设计
首先我们需要一个仓库对象来存储生产者的生产结果,消费者去仓库拿走结果,我们还是用苹果的案例,新建一个仓库:
/**
* 仓库,装载苹果的内存空间
*/
class Warehouse {
private Apple apple;
// 优雅的停止线程标识,仓库是不是还在营业
private boolean run = true;
static class Apple {
}
public synchronized void set(Apple apple) {
if (this.apple != null) {
// 无法放入,需要被消费
try {
super.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
// 放入仓库,唤醒等待的线程
this.apple = apple;
super.notify();
}
}
public synchronized Apple get() {
if (this.apple == null) {
// 仓库空了,无法消费,需要生产
try {
super.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
try {
return this.apple;
} finally {
// 被消费,唤醒等待线程
this.apple = null;
super.notify();
}
}
public boolean isRun() {
return run;
}
public void setRun(boolean run) {
this.run = run;
}
}
生产者
生产者一直做生产工作,往仓库里送苹果:
/**
* 生产者,苹果没了就生产
*/
class Producer implements Runnable {
private Warehouse warehouse;
public Producer(Warehouse warehouse) {
this.warehouse = warehouse;
}
@Override
public void run() {
while (warehouse.isRun()) {
try {
// 模拟延迟,模拟生产比消费快一点
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("生产者:生产一个苹果");
this.warehouse.set(new Warehouse.Apple());
}
}
}
消费者
消费者一直从仓库里拿走苹果:
/**
* 消费者,有苹果就消费
*/
class Consumer implements Runnable {
private Warehouse warehouse;
public Consumer(Warehouse warehouse) {
this.warehouse = warehouse;
}
@Override
public void run() {
while (warehouse.isRun()) {
try {
// 模拟延迟,模拟消费比生产慢一点
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
this.warehouse.get();
System.out.println("消费者:消费一个苹果");
}
}
}
让他们运行起来:
// 装载苹果的仓库内存空间
Warehouse warehouse = new Warehouse();
// 生产者开始生产
Thread threadProducer = new Thread(new Producer(warehouse), "Producer");
// 消费者开始消费
Thread threadConsumer = new Thread(new Consumer(warehouse), "Consumer");
threadProducer.start();
threadConsumer.start();
try {
// 让子线程们执行 4 秒
Thread.sleep(4000);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 优雅的停止线程,仓库停止营业了
warehouse.setRun(false);
完整代码公开在:https://github.com/renfei/demo/blob/master/java/ConcurrentDemo/src/main/java/net/renfei/demo/concurrent/ProducerConsumerDemo.java
总结
在这个案例中,我们使用了线程通知机制,在仓库那里使用了 wait() 和 notify(),也许你会有疑问,唤醒的如果是自己呢?这个是唤醒所有子线程,但咱们还有个 if 判断,如果自己唤醒了自己 if 判断以后,还是会继续 wait(),除非条件满足才进行自己的逻辑。
另外我们使用了更优雅的线程停止方式,那就是根据条件判断,如果直接停止主线程,子线程还有逻辑没有运行完,就会造成数据错误,如果使用条件来控制线程的退出,这样可以保证子线程可以运行一次完整的逻辑再退出。
商业用途请联系作者获得授权。
版权声明:本文为博主「任霏」原创文章,遵循 CC BY-NC-SA 4.0 版权协议,转载请附上原文出处链接及本声明。
相关推荐
猜你还喜欢这些内容,不妨试试阅读一下评论与留言
以下内容均由网友提交发布,版权与真实性无法查证,请自行辨别。- 2021-08-27 16:28:10
- Beijing, Beijing, China
- 回复
微信订阅号
扫码关注「任霏博客」微信订阅号- 大佬 引入jar包那里的 driver class 怎么选的?
- 我也遇到了这个问题,已经解决了,在此分享一下 1、宿主机也要创建kingbase的用户和用户组,并且要查看一下用户和用户组的ID(这个很重要) 2、把data目录的用户和用户组设置为kingbase 3、先不要把data路径挂载到宿主机上,这时就可以正常启动,启动后进入容器,查看一下容器内的kingbase的用户和用户组ID是多少,和第一步的ID是否一致,如果ID一致,那正常挂载目录就行;如果ID不一致,那就需要修改Dockerfile文件,在构建镜像时,修改容器内的用户和用户组ID,必须和宿主机的保持一致。然后重新构建镜像,就可以正常挂载宿主机目录了 4、其实直接修改宿主机的用户和用户组ID也是可以的,但是容器内的ID一般是1000,但是宿主机的这个ID很可能已经被占用了,无法修改,就只能修改容器内的ID
- 接口已经允许跨域请求,也就是说你可以在你的页面上调用,获取用户的公网 IP。 如果你还需要其他需求,可以提交 Issue 给我。
- V008R003C002B0320 这个对应的jdbc链接驱动你在哪里找到的?我也遇到了这个问题。
- WARNING: max_connections should be less than orequal than 10 (restricted by license) HINT: the value of max_connect is set 10 WARNING: max_connections should be less than orequal than 10 (restricted by license) HINT: the value of max_connect is set 10 kingbase: superuser_reserved_connections must be less than max_connections 我按照文档修改了以后,不知道如何重启。
- 然后把数字都改成 1 再启动。 如何重新启动?
- ksql: could not connect to server: No such file or directory Is the server running locally and accepting connections on Unix domain socket "/tmp/.s.KINGBASE.54321"
- 进入容器查看一下日志,是不是启动失败了,日志文件在:/opt/kingbase/logfile
- ksql: could not connect to server: No such file or directory Is the server running locally and accepting connections on Unix domain socket "/tmp/.s.KINGBASE.54321"?
- 先通过 docker exec -it 容器名/id /bin/bash 进入容器,然后在容器中使用 ksql 客户端进行连接数据库:/opt/kingbase/Server/bin/ksql -U system test
- 免费.ml域名10年委托合同到期被马里共和国收回域名经营权
- 从极狐Gitlab看各种中间件技术选型
- 时隔十年首次收到 Google AdSense 的付款
- ga域名被加蓬共和国从Freenom公司手中收回域名经营权
- Freenom 被 Meta(Facebook) 起诉导致暂停 .tk/.ga/.ml/.cf/.gq 等新域名注册
- 生花妙笔信手来 – 基于 Amazon SageMaker 使用 Grounded-SAM 加速电商广告素材生成 [1]
- github.renfei.net 不再完整代理 Github 页面改为代理指定文件
- 优雅的源代码管理(三):本地优雅的使用 Git Rebase 变基
- 优雅的源代码管理(二):Git 的工作原理
- 优雅的源代码管理(一):版本控制系统 VCS(Version Control System)与软件配置管理 SCM(Software Configuration Management)