生产者消费者模式是多线程中最为常见的模式：生产者线程(一个或多个)生成面包放进篮子里(集合或数组)，同时，消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗。虽然它们任务不同，但处理的资源是相同的，这体现的是一种线程间通信方式。
分类：
编程语言 时间：
2018-12-04 20:07:11
阅读次数：
183
生产者消费者模式是多线程中最为常见的模式：生产者线程(一个或多个)生成面包放进篮子里(集合或数组)，同时，消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗。虽然它们任务不同，但处理的资源是相同的，这体现的是一种线程间通信方式。 本文将先说明单生产者单消费者的情况，之后再说明多生产者多消费者 ...
分类：
编程语言 时间：
2018-12-04 11:29:42
阅读次数：
232
1.paramiko模块 用处：连接远程服务器并执行相关操作 使用方法： SSHClient：连接远程服务器并执行基本命令 SSHFtp：连接远程服务器并执行上传下载功能 SSH_RSA：基于公钥密钥进行连接 RSA：非对称密钥验证 公钥：保存在要连接的服务器 私钥：保存在本地机器 2.进程： 什么 ...
分类：
编程语言 时间：
2018-11-26 02:20:59
阅读次数：
201
思路： yield可以使得函数阻塞，next，和send可以解阻塞，实现数据不竞争的生产者消费者模式 代码： import random #随机数，模拟生产者的制造物 def eat(): #消费者 while True: item = (yield) print("消费了：",item) def ...
分类：
其他好文 时间：
2018-11-25 13:16:14
阅读次数：
225
结果： 中断take()方法 结果： 再次修改中断方法： 将get空转，等待标志位的改变 结果显示： customer的run方法结束 再次修改代码： 结果： 前三秒：显示true 完了主函数请求中断消费者，消费者在死循环里面检测到中断的请求之后，将请求通过interrupted()函数，重置一下。 ...
分类：
其他好文 时间：
2018-11-22 11:46:28
阅读次数：
200
Eureka详解 服务消费者模式 消费者启动的时候，使用服务别名，会发送一个rest请求到服务注册中心获取对应的服务信息，让后会缓存到本地jvm客户端中，同时客户端每隔30秒从服务器上更新一次。 可以通过 fetch-inte vall-seconds=30参数进行修以通过eureka.client ...
分类：
编程语言 时间：
2018-11-13 14:24:45
阅读次数：
251
参考教程：http://www.sohu.com/a/237792762_659256 首先介绍每一个类： 1.Message： 这个类的作用是存储一个生产者生产出来的具体的消息，就类似链表队列中的一个节点，自行定义需要存储的内容。 code：消息要执行的具体动作代码 msg：消息内容 target ...
分类：
编程语言 时间：
2018-11-09 21:07:52
阅读次数：
145
相似点：从结构上，反应器模式有点类似生产者消费者模式，即有一个或多个生产者将事件放入一个Queue中，而一个或多个消费者主动的从这个Queue中Poll事件来处理；不同点：Reactor模式则并没有Queue来做缓冲，每当一个Event输入到Reactor 反应器之后，该Reactor 反应器会主动... ...
分类：
其他好文 时间：
2018-11-04 00:39:02
阅读次数：
116
一、前言 这种模式在生活是最常见的，那么它的场景是什么样的呢？ 下面是我假象的，假设有一个仓库，仓库有一个生产者和一个消费者，消费者过来消费的时候会检测仓库中是否有库存，如果没有了则等待生产，如果有就先消费直至消费完成；而生产者每天的工作就是先检测仓库是否有库存，如果没有就开始生产，满仓了就停止生产 ...
分类：
编程语言 时间：
2018-10-28 13:43:04
阅读次数：
188
引言 JDK中除了上文提到的各种并发容器，还提供了丰富的阻塞队列。阻塞队列统一实现了BlockingQueue接口，BlockingQueue接口在java.util包Queue接口的基础上提供了put(e)以及take()两个阻塞方法。他的主要使用场景就是多线程下的生产者消费者模式，生产者线 ...
分类：
编程语言 时间：
2018-10-26 00:49:20
阅读次数：
199
