一、生产者消费者模型 我们去超市商店等地购买商品时，我们大部分人都会说自己是消费者，而超市的各大供货商、工厂等，自然而然地也就成了我们的生产者。如此一来，生产者有了，消费者也有了，那么将二者联系起来的超市又该作何理解呢？诚然，它本身是作为一座交易场所而诞生。 上述情形类比到实际的软件开发过程中，经常 ...
分类：
其他好文 时间：
2018-08-30 02:02:52
阅读次数：
166
在上一篇文章中说过使用thread.join()方法、newSingleThreadExecutor单线程池来控制线程执行顺序。在文章的末尾我提出了一种构想，可否使用经典的生产者和消费者模型来控制执行顺序。在本文中，我将使用CountDownLatch来解决这个问题。 上图是countDownLat ...
分类：
编程语言 时间：
2018-08-30 01:52:17
阅读次数：
290
交互式并发进程通过信号量及PV操作可以实现进程的互斥与同步，例如生产者-消费者就是一组相互协作的进程，它们通过信号量来协同工作，并引入有界缓冲区来存取。这种低级通信方式不方便而且局限性很大。 管程适用于高级程序设计编程，它把分散在各进程中的临界区集中统一管理，采用阻塞/唤醒+集中临界区和一次状态测试 ...
分类：
系统相关 时间：
2018-08-29 17:57:52
阅读次数：
286
类 Exchanger 的功能可以使2个线程之间传输数据，比生产者/消费者模式方便。 Exchanger类的结构很简单，重点就是exchange()方法。 exchange()方法是阻塞执行的，可以设置超时时间，调用不同的api即可。 exchange 的 英文意思就是交换，而对于线程而言也是这样的 ...
分类：
编程语言 时间：
2018-08-28 20:25:43
阅读次数：
140
信号量Semaphores 和信号类似，信号量也是一种同步多个线程的方式，简单来讲，信号量就是装有一些令牌的容器。当一个线程在执行过程中，就可能遇到一个系统调用来获取信号量令牌，如果这个信号量包含多个令牌，线程就会继续执行，同时信号量令牌的数量就会减一。如果此时信号量中没有令牌，线程就会被置于等待状 ...
分类：
其他好文 时间：
2018-08-28 14:20:31
阅读次数：
196
生产者消费者模型 主要用于解耦 借助队列实现生产者消费者模型 (队列(First In First Out 简称 : FIFO) : 先进先出 ) joinablequeue模块 管道 管道是不安全的 , 一般单进程不要用管道 用于多进程之间通信的一种方式 如果在单进程中使用管道,那么就是con1收 ...
分类：
编程语言 时间：
2018-08-27 18:18:54
阅读次数：
190
1、rabbitMQ 与ptyhon 进程queue 区别。进程queue 主要用户Python父子进程之间或者统一进程不同子进程。rabbit可以用户不同语言之前的相互交流，socket可以实现同样功能，但是较为复杂。 2、 rabbitMQ 消息轮训。一个生产者对多个消费者时候。会自动将消息轮训 ...
分类：
编程语言 时间：
2018-08-26 11:56:37
阅读次数：
176
最近用Maxwell解析MySQL的Binlog，发送到Kafka进行处理，测试的时候发现一个问题，就是Kafka的Offset严重倾斜，三个partition，其中一个的offset已经快200万了，另外两个offset才不到两百。Kafka数据倾斜的问题一般是由于生产者使用的Partition接 ...
分类：
其他好文 时间：
2018-08-24 19:23:25
阅读次数：
369
什么是MQ？ MQ全程Message Queue，消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费者-生产者模型的典型代表。一端往消息队列中不断写消息而另一端则可以读取队列中的消息。 RabbmitMQ相关组成： producer：消息生产者，生产消息并投递到队列之中。 cusumer ...
分类：
其他好文 时间：
2018-08-24 18:08:49
阅读次数：
540
