单生产者与单消费者 示例: public class ProduceConsume { public static void main(String[] args) { String lock = new String(""); Produce produce = new Produce(lock) ...
分类:
编程语言 时间:
2020-03-18 23:56:02
阅读次数:
118
python基础 信号量 semaphore evevt 线程queue 生产者消费者模型 ...
分类:
编程语言 时间:
2020-03-17 23:50:16
阅读次数:
72
线程通信中要预防虚假唤醒 注意(在哪里停就在哪里启动) class shareDataOne{ private int number = 0; public synchronized void incr() throws InterruptedException { if(number != 0){ ...
分类:
编程语言 时间:
2020-03-14 20:31:47
阅读次数:
73
kafka这个东西到底是怎么一回事,其实很简单,就是一个消息中间件,可以订阅消息,也可以发布消息 所谓订阅,就是消费 所谓发布,就是生产 在分布式系统中,如果消费方在处理一项任务中需要联系到生产方,那么在调用对方系统的时候,如果对方系统调用失败,或者对方系统崩溃,而我方消费者系统仍需要继续执行的时候 ...
分类:
其他好文 时间:
2020-03-14 16:24:50
阅读次数:
46
[toc] 生产者根据不同的业户需求和性能需求,选择合适的发送方式,可以达到最大效率。 具体选择哪一种发送方式,要考虑实际的业务场景。 简单来说: 1、保存用户点击情况、不重要的日志分析等大频率储存,但不担心丢失的情况下使用异步发送 2、订单、支付信息,信息量不一定很多,但是非常重要,就需要采取同步 ...
分类:
编程语言 时间:
2020-03-13 20:43:39
阅读次数:
80
Java线程池七个参数详解 Java多线程开发时,常常用到线程池技术,这篇文章是对创建java线程池时的七个参数的详细解释。 从源码中可以看出,线程池的构造函数有7个参数,分别是corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、thr ...
分类:
编程语言 时间:
2020-03-11 11:12:05
阅读次数:
71
今天发现大家对NSQ等组件的集群原理还不了解,所以这遍文章对一些常见组件的集群原理做一个汇总整理。我会不定期更新,增加一些新的组件或修改错误。 1 NSQ NSQ集群比较简单,主要包含4个部分,一是生产者(图上没画)、二是nsq实例(nsqd)、三是服务发现nsqlookupd、四是消费者(Coms ...
分类:
其他好文 时间:
2020-03-10 15:59:14
阅读次数:
39
本次的记录内容包括: 1.Java调用生产者APi流程 2.Kafka生产者Api的使用及说明 3.Kafka消费者Api的使用及说明 4.Kafka消费者自动提交Offset和手动提交Offset 5.自定义生产者的拦截器,分区器 那么接下来我就带大家熟悉以上Kafka的知识说明 1.Java调用 ...
分类:
编程语言 时间:
2020-03-10 15:47:49
阅读次数:
74
生活中我们经常遇到观察者模式的案例。 例如,我们去商场购物,注册了一家店的会员,一旦这家店有活动,你的手机就会收到一些推送消息,是不是? 在例如,我们看某个电视台的节目,这个电视台放什么节目我们就会看到什么节目。 这些都是典型的生产者与消费者的案例。 所谓的观察者模式,定义了一种一对多的依赖关系,能 ...
分类:
编程语言 时间:
2020-03-10 11:50:05
阅读次数:
87
RabbitMQ死信队列俗称,备胎队列;消息中间件因为某种原因拒收该消息后,可以转移到死信队列中存放,死信队列也可以有交换机和路由key等。 产生死信队列的原因 消息投递到MQ中存放 消息已经过期 队列达到最大的长度 (队列容器已经满了)生产者拒绝接受消息 消费者消费多次消息失败,就会转移存放到死信 ...
分类:
其他好文 时间:
2020-03-09 15:07:17
阅读次数:
47