In this tutorial, we show simple implementations of barriers and producer-consumer queues using ZooKeeper. We call the respective classes Barrier and ...
分类：
其他好文 时间：
2014-12-14 14:24:59
阅读次数：
385
（1）线程同步，实现“生产者消费者问题”
要求：缓冲区大小为20，生产者每次放一个产品，消费者每次取走一个产品；生产者和消费者至少2个。
（2）代码如下：
#include
#include
#include
#include
void *producter_f (void *arg); /*生产者*/
void *consumer_f (void *arg); /*...
分类：
编程语言 时间：
2014-11-30 14:11:37
阅读次数：
261
多线程： 生产与消费1.生产者Producer生产produce产品，并将产品放到库存inventory里；同时消费者Consumer从库存inventory里消费consume产品。2.库存inventory的总量（最大库存量100）是有限的。如果库存inventory满了，生产者不能在库存inv...
分类：
编程语言 时间：
2014-11-27 14:12:17
阅读次数：
225
1.pocket apipocket新版api不允许直接发送用户名跟密码，所以需要先申请app的consumer_key，然后再get_request_token，拿到一个request_token，再通过consumer_key和request_token用浏览器访问authorize网站，之后手...
分类：
编程语言 时间：
2014-11-24 00:46:41
阅读次数：
354
前言：昨天尝试用Java自行实现生产者消费者问题（Producer-Consumer Problem），在coding时，使用到了Condition的await和signalAll方法，然后顺便想起了wait和notify，在开发中遇到了一个问题：wait、notify等阻塞和恢复的时机分别是什么？...
分类：
编程语言 时间：
2014-11-19 18:19:32
阅读次数：
170
在publish/subscribe模式中使用fanout类型有个缺陷，就是不能选择性接收的消息。我们可以让consumer获得所有已发布的消息中指定的几个消息。在之前的例子中我们这样绑定exchange和队列：channel.queueBind(queueName, EXCHANGE_NAME, ...
分类：
其他好文 时间：
2014-11-15 21:39:10
阅读次数：
299
这次我们试试publish / subscribe模式，也就是将一个消息发送给多个consumer。这里用一个简单的小程序来说明publish / subscribe。由一个provider提供消息，这个消息会被多个consumer接收。consumer对同一个消息做出不同的反应，比如打印、保存到文...
分类：
其他好文 时间：
2014-11-15 21:29:33
阅读次数：
348
RabbitMQ是个健壮、易用、开源、支持多种操作系统和语言的message broker。当然，一切的前提是机器里面正在运行着rabbitmq-server。点击下面的图片下载：rabbitMQ和AMQP的关系是什么样的？rabbitMQ负责哪部分?如图所示，就是provider和consumer...
分类：
其他好文 时间：
2014-11-15 20:14:40
阅读次数：
285
public class Consumer {
public static void main(String[] args) throws IOException, ShutdownSignalException, ConsumerCancelledException, InterruptedException{
ConnectionFactory connFactory = new Con...
分类：
其他好文 时间：
2014-11-14 00:20:45
阅读次数：
144
#include#include#include#include#includevoid*consumer(void*p){ sleep(10);//这句代码，主要是为了测试用的，说白了就是等到所有线程创建完毕后，在输出线程标识符 printf("(%lu) %lu\n",pthr...
分类：
编程语言 时间：
2014-11-13 14:33:38
阅读次数：
310
