生产者消费者模式 在并发编程中使用生产者和消费者模式能够解决绝大多数并发问题， 该模式通过平衡生产线程和消费线程的工作能力来提高程序的整体处理数据的速度 生产者和消费者模式来源 在线程世界里, 生产者就是生产数据的线程，消费者就是消费数据的线程。 在多线程开发当中，如果生产者处理速度很快，而消费者处 ...
分类：
编程语言 时间：
2018-09-06 22:57:55
阅读次数：
216
Python提供的Condition对象提供了对复杂线程同步问题的支持。Condition被称为条件变量，除了提供与Lock类似的acquire和release方法外，还提供了wait和notify方法。线程首先acquire一个条件变量，然后判断一些条件。如果条件不满足则wait；如果条件满足，进 ...
分类：
其他好文 时间：
2018-09-03 15:34:03
阅读次数：
166
在上一篇文章中说过使用thread.join()方法、newSingleThreadExecutor单线程池来控制线程执行顺序。在文章的末尾我提出了一种构想，可否使用经典的生产者和消费者模型来控制执行顺序。在本文中，我将使用CountDownLatch来解决这个问题。 上图是countDownLat ...
分类：
编程语言 时间：
2018-08-30 01:52:17
阅读次数：
290
1、生产者和消费者模型 作用：用于解耦。 原理：生产者将生产的数据放到缓存区，消费者从缓存区直接取。借助队列来实现该模型（队列就是缓存区） 队列是安全的，自带锁机制。 q = Queue(num) num 为队列的最大长度，可以自己设定。 q.put(): 向队列里放数据，如果数据满了就阻塞等待，如 ...
分类：
其他好文 时间：
2018-08-22 22:48:11
阅读次数：
179
一 .概述 当我们实现了原子性操作的时候,我们又会遇到一个问题,那就是线程之间通信的问题.所谓的线程通信,指的就是线程间的执行顺序是需要进行一定的控制的. 我们拿最经典的生产者和消费者模型进行说明: 在这里,我们使用wait()和notify()方法进行实现. 但是我们发现了一个问题,如果我们实现线 ...
分类：
其他好文 时间：
2018-08-22 14:07:00
阅读次数：
123
# 生产者消费者模型 # 在线程世界里，生产者就是生产数据的线程，消费者就是消费数据的线程 # 如果生产者速度快而消费者处理速度慢，或生产者处理速度慢而消费者处理速度快，这样就会发生等待 # 为了解决这个问题于是就引入了生产者和消费者模式 # 生产者消费者模式是通过一个容器来解决生产者与消费者强耦合... ...
分类：
其他好文 时间：
2018-08-18 22:28:38
阅读次数：
179
4.6 Message Delivery Semantic（消息传递语义） 现在我们了解了生产者和消费者的工作方式，让我们讨论Kafka在生产者和消费者之间提供的语义保证。显然，可以提供多种可能的消息传递保证： 最多一次 -消息可能会丢失，但永远不会被重新发送。 至少一次 -消息永远不会丢失，但可能 ...
分类：
其他好文 时间：
2018-08-18 10:28:59
阅读次数：
172
一.总共分为三个目录: dubbo-api 服务的接口用于对接客户端和服务端 dubbo-client 客户端配置文件为:consumer.xml dubbo-service 服务端配置文件为:provide.xml 二.配置文件 1.consumer.xml: 2.provide.xml: 3po ...
分类：
编程语言 时间：
2018-08-17 11:22:46
阅读次数：
188
添加Maven依赖： 使用rabbitmq client的最新Maven坐标： 添加账户 默认情况下，访问RabbitMQ服务的用户名和密码都是“guest”，这个账号有限制，默认只能通过本地网络（如localhost）访问，远程网络访问受限，所以在实现生产和消费消息之前，需要另外添加一个用户，并设 ...
分类：
编程语言 时间：
2018-08-16 23:49:34
阅读次数：
307
windows下 安装 rabbitMQ 及操作常用命令 rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。它遵循Mozilla Public License开源协议，采用 Erlang 实现的工业级的消息队列(MQ)服务器，Rabbit MQ 是建立在Erlang OTP ...
