概念 什么是设计模式？ ? 设计模式是别人已经总结好的可以解决问题的方案 ? 设计模式23种，常用的是单例设计模式，工厂设计模式，生产者消费者设计模式，代理委托设计模式等 什么是单例设计模式？ ? 单例：单个的实例，单个的对象 ? 程序在运行的过程中，确保某一个类只能有一个实例【对象】，不管在程序的 ...
分类：
其他好文 时间：
2018-11-22 22:31:15
阅读次数：
178
思路： 利用thread类中，run方法在子线程中调用，其他方法在主线程调用，所以将生产者写入主线程，将消费者写入run函数中在子线程中执行，完成生产者消费者模型 注意： 1. 要在 init 函数中实例化一个Queue队列作为生产者消费者中介 2. 要在 init 函数中把daemon值设为Tru ...
分类：
编程语言 时间：
2018-11-22 14:28:52
阅读次数：
235
结果： 中断take()方法 结果： 再次修改中断方法： 将get空转，等待标志位的改变 结果显示： customer的run方法结束 再次修改代码： 结果： 前三秒：显示true 完了主函数请求中断消费者，消费者在死循环里面检测到中断的请求之后，将请求通过interrupted()函数，重置一下。 ...
分类：
其他好文 时间：
2018-11-22 11:46:28
阅读次数：
200
注意 ： mgr = multiprocessing.Manager() 生成了一个守护进程，如果主进程完毕，mgr这个实例也没有了,所以在结尾加了mgr.join()才能运行 代码： ...
分类：
系统相关 时间：
2018-11-21 22:24:31
阅读次数：
253
MQ全称为Message Queue, 是一种分布式应用程序的的通信方法，它是消费-生产者模型的一个典型的代表，producer往消息队列中不断写入消息，而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表，是一款基于AMQP协议可复用的企业消息系统。业务上， ...
分类：
其他好文 时间：
2018-11-20 23:34:30
阅读次数：
399
在之前的博客中，介绍了Kafka Web Console这 个监控工具，在生产环境中使用，运行一段时间后，发现该工具会和Kafka生产者、消费者、ZooKeeper建立大量连接，从而导致网络阻塞。并且这个 Bug也在其他使用者中出现过，看来使用开源工具要慎重！该Bug暂未得到修复，不得已，只能研究下 ...
分类：
其他好文 时间：
2018-11-20 11:29:52
阅读次数：
177
之前写过一篇《从源码分析如何优雅的使用 Kafka 生产者》 ，有生产者自然也就有消费者。 ...
分类：
其他好文 时间：
2018-11-20 10:20:55
阅读次数：
239
Java队列中存在有界和无界2种，区别在于有界就是有限制的，无界是无限的。 在并发中存在阻塞和非阻塞。 阻塞：生产者写入队列慢的时候就会进入阻塞，等待消费者消费。当一个线程试图对一个空队列进行出队列操作时，它将会被阻塞，除非有另一个线程进行了入队列操作。 第一：ConcurrentLinkedQue ...
分类：
其他好文 时间：
2018-11-18 23:07:35
阅读次数：
180
import threading,timeimport queueq = queue.Queue(maxsize=10)def Producer(name): count = 1 while True: q.put("骨头%s" % count) print("生产了骨头",count) count ...
分类：
其他好文 时间：
2018-11-18 18:18:22
阅读次数：
225
一 生产者消费者模型介绍 为什么要使用生产者消费者模型 生产者指的是生产数据的任务，消费者指的是处理数据的任务，在并发编程中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。为了 ...
分类：
其他好文 时间：
2018-11-18 11:27:34
阅读次数：
188
