http://www.cnblogs.com/dolphin0520/p/3920385.html Java并发编程:线程间协作的两种方式:wait、notify、notifyAll和Condition 在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作。比如说最经典的生产者-消费者 ...
分类:
编程语言 时间:
2018-10-22 14:45:34
阅读次数:
185
一、 Celery的架构图: task producer - 任务生产者 顾名思义就是发起调度任务的,然后交给任务队列去处理。简单的Python代码、耦合在Django/Flask Web 服务里请求任务比如调用备份或者调用初始化安装机器的任务,在程序里面调用Celery任务装饰的函数,产生任务并分 ...
分类:
其他好文 时间:
2018-10-22 00:01:41
阅读次数:
132
Kafka是一个分布式发布订阅消息系统。由LinkedIn开发并已经在2011年7月成为apache顶级项目。kafka在LinkedIn,Twitte等许多公司都得到广泛使用,主要用于:日志聚合,消息队列,实时监控等。0.8版本开始,kafka支持集群内复制,从而提高可用性和系统稳定性,这篇文章主要概述kafka复制的设计。复制有了复制后,kafka客户端将会得到如下好处:生产者能在出现故障的时
分类:
其他好文 时间:
2018-10-21 21:52:55
阅读次数:
293
一、用法 Activate注解表示一个扩展是否被激活(使用),可以放在类定义和方法上,dubbo用它在spi扩展类定义上,表示这个扩展实现激活条件和时机。 表示该类只在生产者生效。 二、源码解析 先看下接口定义: 它有两个设置过滤条件的字段,group,value 都是字符数组。用来指定这个扩展类在 ...
分类:
其他好文 时间:
2018-10-21 20:37:29
阅读次数:
347
# 管道实现生产者消费者模型 # # 应该特别注意管道端点的正确管理问题,如果是生产者或消费者中都没有使用管道的端点就应该将它关闭 # 这也说明了为何在生产者中关闭了管道的输出端,在消费者中关闭管道的输入端。如果忘记执行这个步骤 # 程序可能在消费者中的recv()操作上挂起。管道是由操作系统进行引... ...
分类:
其他好文 时间:
2018-10-21 16:07:03
阅读次数:
152
# 多进程的生产者消费者模型 # 队列 # 队列是进程安全的,同时只能有一个进程从队列中取到数据 # 生产者消费者模型 # 为什么要这个模型 # 这个模型经常性的解决数据的供需不平衡的问题 # 经常有两拨人,一拨是生产数据的,一拨是消费数据的。 # 消费者指的是使用数据处理数据的一端 # 生产数据的... ...
分类:
系统相关 时间:
2018-10-21 14:23:25
阅读次数:
164
Kafka介绍 Kafka是Apache软件基金会开发的一个开源流处理平台,由Java和Scala编写;Kafka是一种高吞吐、分布式、基于订阅发布的消息系统。 Kafka名称解释 Producer:生产者 Consumer:消费者 Topic:消息主题,每一类的消息称之为一个主题 Broker:K ...
分类:
其他好文 时间:
2018-10-21 13:09:57
阅读次数:
271
小话工具 从发明石器到铁器,到蒸汽机再到互联网,人类从石器时代走到农耕文明,到工业文明,再到信息文明。人类对工具的掌握,实现了物质——能量——信息的三重跨越。 工具不仅提高着人类的生产力,还在反向影响着着人类的行为和关系。 墨刀这个产品作为一个工具生产者,深感任重道远。 墨刀V4.0 松下幸之助曾说 ...
分类:
其他好文 时间:
2018-10-20 16:16:07
阅读次数:
165
一.Kafka中的核心概念 Producer: 特指消息的生产者Consumer :特指消息的消费者Consumer Group :消费者组,可以并行消费Topic中partition的消息Broker:缓存代理,Kafa 集群中的一台或多台服务器统称为 broker。Topic:特指 Kafka ...
分类:
其他好文 时间:
2018-10-19 00:09:07
阅读次数:
174
多线程设计模式第三篇,介绍基础的生产者-消费者模式和实用的读写锁模式
分类:
编程语言 时间:
2018-10-18 18:10:39
阅读次数:
223