一、Java中的阻塞队列 在多线程之间通信中,多个线程共享一个进程所分配的资源,共享内存是一种常见的通信方式,而阻塞队列则是其实现方式的一种,例如经典的生产者-消费者模式。 A Queue that addtionally supports operations that wait for the ...
分类:
编程语言 时间:
2016-11-06 02:25:03
阅读次数:
374
两个线程一个生产者个一个消费者 需求情景 两个线程,一个负责生产,一个负责消费,生产者生产一个,消费者消费一个 涉及问题 同步问题:如何保证同一资源被多个线程并发访问时的完整性。常用的同步方法是采用标记或加锁机制 wait() / nofity() 方法是基类Object的两个方法,也就意味着所有J ...
分类:
编程语言 时间:
2016-11-04 01:08:08
阅读次数:
315
【前言】 协同程序与线程差不多,也就是一条执行序列,拥有自己独立的栈、局部变量和指令指针,同时又与其它协同程序共享全局变量和其它大部分东西。从概念上讲,线程与协同程序的主要区别在于,一个具有多个线程的程序可以同时运行几个线程,而协同程序却需要彼此协作的运行。就是说,一个具有多个协同程序的程序在任意时 ...
分类:
其他好文 时间:
2016-10-31 18:43:49
阅读次数:
242
JIRA的生产者把JIRA定义为Professional Issue Tracker,即它是一个专业的问题跟踪管理的软件。这里的”问题”对应的英文单词是Issue,所以含义比较广,包括Bug,Task,Enhancement,Improvement等等跟软件开发相关的名词。跟踪管理即对问题的整个生命 ...
分类:
其他好文 时间:
2016-10-30 11:18:05
阅读次数:
242
转载请注明出处:http://www.cnblogs.com/xiaodf/ 本示例展示了一个RocketMQ producer的简单实现,通过解析文本文件获取输入数据,将数据经过Avro序列化后发送到RocketMQ。 程序通过stdin.xml配置文件获取主要参数值,stdin.xml文件内容如 ...
分类:
其他好文 时间:
2016-10-26 14:13:45
阅读次数:
282
1 package day2016_10_25_Thread; 2 3 import java.util.LinkedList; 4 import java.util.Random; 5 6 public class Productor { 7 public static void main(Str ...
分类:
编程语言 时间:
2016-10-26 06:42:23
阅读次数:
177
Java数据结构之 Queue队列 队列(简称作队,Queue)也是一种特殊的线性表,队列的数据元素以及数据元素间的逻辑关系和线性表完全相同,其差别是线性表允许在任意位置插入和删除,而队列只允许在其一端进行插入操作在其另一端进行删除操作。 队列中允许进行插入操作的一端称为队尾,允许进行删除操作的一端 ...
分类:
编程语言 时间:
2016-10-25 14:04:20
阅读次数:
282
1.不使用锁的话,可能会产生线程的竞争:当共享一个对象(变量或者一个方法)加锁的操作 在threading模块中,定义两种类型的琐:threading.Lock和threading.RLock。它们之间有一点细微的区别,通过比较下面两段代码来说明:import threading lock = th ...
分类:
其他好文 时间:
2016-10-23 12:00:20
阅读次数:
243
fanout交换器会把发送给它的所有消息发送给绑定在它上面的队列,起到广播一样的效果。 本里使用实际业务中常见的例子, 订单系统:创建订单,然后发送一个事件消息 积分系统:发送订单的积分奖励 短信平台:发送订单的短信 消息生产者SenderWithFanoutExchange 消费消费者Receiv ...
分类:
其他好文 时间:
2016-10-22 23:31:26
阅读次数:
369
本例使用topic接收警告、错误的日志,并根据匹配的路由规则发送给不同的Queue队列来处理的例子: 日志生产者SenderWithTopicExchange 消息消费者ReceiverWithTopicExchange 结果输出: 消息处理流程: ...
分类:
其他好文 时间:
2016-10-22 17:44:11
阅读次数:
228