用 threading.Event() 也可以实现生产者/消费者模式 （自己拍脑袋想出来的，无法知道其正确性，请大神告知为谢！） import threading import time import random products = 20 class Producer(threading.Thr
分类：
编程语言 时间：
2016-02-03 06:40:07
阅读次数：
286
我们已经知道，对公共资源进行互斥访问，可以使用Lock上锁，或者使用RLock去重入锁。 但是这些都只是方便于处理简单的同步现象，我们甚至还不能很合理的去解决使用Lock锁带来的死锁问题。 要解决更复杂的同步问题，就必须考虑别的办法了。 threading提供的Condition对象提供了对复杂线程
分类：
编程语言 时间：
2016-02-03 01:54:21
阅读次数：
179
ActiveMQ支持多种通讯协议TCP/UDP等，我们选取最常用的TCP来分析ActiveMQ的通讯机制。首先我们来明确一个概念: 客户(Client)：消息的生产者、消费者对ActiveMQ来说都叫作客户。 消息中介(Message broker)：接收消息并进行相关处理后分发给消息的消费者. 为
分类：
其他好文 时间：
2016-02-02 20:38:23
阅读次数：
186
多线程的开发中有一个最经典的操作案例，就是生产者-消费者，生产者不断生产产品，消费者不断取走产品。 package com.vince; /** * 生产者与消费者案例 * @author Administrator * */ public class ThreadDemo4 { public st
分类：
编程语言 时间：
2016-02-01 18:17:15
阅读次数：
118
NSOpertaionQueue用GCD构建封装的，是GCD的高级抽象。GCD仅仅支持FIFO队列，而NSOperationQueue中的队列可以被重新设置优先级，从而实现不同操作的执行顺序调整。GCD不支持异步操作之间的依赖关系设置。如果某个操作的依赖另一个操作的数据（生产者-消费者模型是其中之一
分类：
其他好文 时间：
2016-01-29 11:49:14
阅读次数：
172
生产者/消费者模式简介用来干嘛的？生产者/消费者模式的产生主要目的就是为了解决非同步的生产与消费之间的问题。什么是非同步呢？
比如我刚刚生产了某个产品，而此时你正在打游戏，没空来取，要打完游戏来取，这就导致了我生产产品和你取产品是两个非同步的动作，你不知道我什么时候生产完产品，而我也不知道你什么时候来取。而生产者/消费者模式就是解决这个非同步问题的，因为肯定不可能我生产完一个就给你打个电话...
分类：
其他好文 时间：
2016-01-27 17:24:52
阅读次数：
251
生产者、消费者模式是多线程中的经典问题。通过中间的缓冲队列，使得生产者和消费者的速度可以相互调节。对于比较常见的单生产者、多消费者的情况，主要有以下两种策略：通过volatilebooleanproducerDone＝false来标示是否完成。生产者结束后标示为true,消费者轮询这个变量来决..
分类：
编程语言 时间：
2016-01-25 00:09:28
阅读次数：
1391
Java多线程编程中，常用的多线程设计模式包括：Future模式、Master-Worker模式、Guarded Suspeionsion模式、不变模式和生产者-消费者模式等。这篇文章主要讲述Future模式，关于其他多线程设计模式的地址如下：关于其他多线程设计模式的地址如下：关于Master-Wo...
分类：
编程语言 时间：
2016-01-22 17:12:44
阅读次数：
347
上一篇记录了几种环形缓冲区的设计方法和环形缓冲区在生产者消费者模式下的使用（并发有锁），这一篇主要看看怎么实现并发无锁。0、简单的说明首先对环形缓冲区做下说明：环形缓冲区使用改进的数组版本，缓冲区容量为2的幂缓冲区满阻塞生产者，消费者进行消费后，缓冲区又有可用资源，由消费者唤醒生产者缓冲区空阻塞消费...
分类：
其他好文 时间：
2016-01-20 22:21:56
阅读次数：
223
简单说kafka是一个高吞吐的分部式消息系统kafka的架构? producer：消息生存者? consumer：消息消费者? broker：kafka集群的server，负责处理消息读、写请求，存储消息? topic：消息队列/分类? Queue里面有生产者消费者模型? broker就是代理，在k...
分类：
其他好文 时间：
2016-01-19 20:54:59
阅读次数：
245
