队列是常用的数据结构，采用的FIFO(first in firstout)原则，新元素（等待进入队列的元素）总是被插入到尾部，而读取的时候总是从头部开始读取。在计算中队列一般用来做排队(如线程池的等待排队，锁的等待排队)，用来做解耦（生产者消费者模式），异步等等。在java多线程应用中，队列的使用率 ...
分类：
其他好文 时间：
2019-03-01 18:46:11
阅读次数：
238
进程锁 进程中的数据安全问题:当多个进程同时去访问同一段数据的时候,就容易产生数据的不安全 给代码上锁,实际上是对这一段代码有一个串行的要求,所有的异步在锁内都变成了同步的,同时大大降低了代码的效率 但是在数据安全面前,所有的效率问题都不重要 进程通信 IPC 队列 自带进程锁 特点:先进先出 进程 ...
分类：
系统相关 时间：
2019-02-28 21:07:48
阅读次数：
269
# Author:XiangLiangimport threading,timeimport queueq = queue.Queue(maxsize=10)def Producer(name): count = 1 while True: q.put("骨头 %s" %count) print(" ...
分类：
编程语言 时间：
2019-02-27 01:33:47
阅读次数：
173
主要用于生产者，消费者模型消费者消费速度大于生产者生产速度例子classDispatcher:def__init__(self):self.data=Noneself.event=threading.Event()defproduce(self,total):for_inrange(total):data=random.randint(0,100)logging.info(data)self.da
分类：
其他好文 时间：
2019-02-26 21:05:45
阅读次数：
176
在配置kafka和storm的时候, 经常的会出现一些问题, 主要在以下几个: 1. 打jar包上去storm集群的时候会出现jar包冲突,类似于log4j或者sf4j的报错信息. 2. kafka本地Java生产者和消费者无法消费数据 3. kafkaSpout的declareFields到底是什 ...
分类：
其他好文 时间：
2019-02-26 17:43:47
阅读次数：
201
一、生产者、消费者协作机制： 生产者线程和消费者线程通过共享队列进行协作，生产者将数据或任务放到队列上，而消费者从列队上取数据或任务，如果队列长度有限，在队列满的时候，生产者等待，而在队列为空的时候，消费者等待。 二、同步协作机制： 在一些程序，尤其是模拟仿真程序中，要求多个线程同时开始。 三、主从 ...
分类：
编程语言 时间：
2019-02-25 19:02:52
阅读次数：
223
Rabbit的消息确认机制(事务+confirm)在rabbmitmq中我们可以通过持久化数据解决rabbitmq服务器异常的数据丢失问题问题：生产者将消息发送出去之后消息到底有没有到达rabbitmq服务器默认的情况是不知道的;事物两种方式：AMQP实现了事务机制Confirm模式事务机制txSe ...
分类：
其他好文 时间：
2019-02-24 10:30:04
阅读次数：
150
RabbitMQ是常见的消息中间件。也许是还是不够了解的缘故，感觉功能还好吧。 讲到队列，大家脑子里第一印象是下边这样的。 P生产者推送消息-->队列-->C消费者取出消息 结构很简单，但是RabbitMQ应该是为了丰富的功能吧，把“队列”拆分了。 分成了：exchange（交换机）和queue（队 ...
分类：
Web程序 时间：
2019-02-24 00:21:00
阅读次数：
227
渠道策略是整个营销系统的重要组成部分，它对降低企业成本和提高企业竞争力具有重要意义。是规划中的重中之重。它同产品策略、价格策略、促销策略一样，也是企业是否能够成功开拓市场、实现销售及经营目标的重要手段。 一、分销渠道的常规形式 营销渠道就是商品和服务从生产者向消费者转移过程的具体通道或路径。市场营销 ...
分类：
其他好文 时间：
2019-02-22 23:36:32
阅读次数：
221
一、multiprocess.process模块 1.process类 Process([group [, target [, name [, args [, kwargs]]]]])，由该类实例化得到的对象，表示一个子进程中的任务（尚未启动） 强调： 1. 需要使用关键字的方式来指定参数 2. a ...
分类：
编程语言 时间：
2019-02-22 16:39:01
阅读次数：
207
