码迷,mamicode.com
首页 >  
搜索关键字:工作队列    ( 217个结果
rabbitmq使用dead letter机制来进行retry
首先建立 工作exchange和工作queue,指定工作队列的x-dead-letter-exchange到重试exchenge var workQueueArgs = new Dictionary { { "x-dead-letter-exchange", RETRY_EXCHANGE }, };...
分类:其他好文   时间:2014-12-31 14:23:10    阅读次数:5423
RabbitMQ术语
工作队列:Working Queue分配:多个客户端接收同一个Queue,如何做负载均衡(分配)。 Round-robin分配:多个接收端接收同一个Queue时,采用了Round-robin分配算法,即伦叫调度-依次分配给各个接收方。消息确认: 默认开启了消息确认(接收方接收到消息后,立即向服务.....
分类:其他好文   时间:2014-12-30 13:24:49    阅读次数:198
Java工作队列和线程池
分类:【java】2013-11-21 20:29917人阅读评论(3)收藏举报背景 最近的需要做一个与设备通信的web项目。当然,我们需要写好与设备之间的通信协议(socket)。大致的时序逻辑时:当用户用浏览器点击页面某一控件后,它就向后台发送一个post请求,后台解析前台发送的参数,然后封装成...
分类:编程语言   时间:2014-12-17 06:47:00    阅读次数:231
Java 并发编程(四)阻塞队列和生产者-消费者模式
阻塞队列提供了可阻塞的 put 和 take 方法,以及支持定时的 offer 和 poll 方法。如果队列已经满了,那么put方法将阻塞直到有空间可以用;如果队列为空,那么take方法将一直阻塞直到有元素可用。队列可以使有界的,也可以是无界的,无界队列永远都不会充满,因此无界队列上的put方法永远不会阻塞。一种常见的阻塞生产者-消费者模式就是线程池与工作队列的组合,在 Executor 任务执行框架中就体现了这种模式。 意义:该模式能简化开发过程,因为他消除了生产者和消费者类之间的代码依赖性,此外,该模式...
分类:编程语言   时间:2014-12-06 21:37:31    阅读次数:341
大数据文件处理
在处理大数据文件时,利用"生产者-消费者"线程模型进行处理,代码实现如下:/** * 文件处理类 * */public class FileProcessor { /**读取文件的路径*/ private String path = ""; /**指定默认工作队列的大小*/ public sta.....
分类:其他好文   时间:2014-12-06 00:03:30    阅读次数:252
一个C#多线程的工作队列
多线程添加元素到队列中,队列根据绑定的事件进行自动处理,可以设置WorkSequential属性来实现对队列处理的单线程(严格顺序处理)或者多线程处理(循序出队,但是多线程处理,不保证对队列元素的处理顺利)的选择。代码/***********多线程的工作队列*************** * 此工作...
分类:编程语言   时间:2014-11-20 21:36:00    阅读次数:253
RabbitMQ中文入门教程
原文地址:http://adamlu.net/dev/2011/09/rabbitmq-get-started/这系列教程是翻译官方入门教程。第一部分:Hello World第二部分:工作队列(Work queues)第三部分:发布/订阅(Publish/Subscribe)第四部分:路由(Rout...
分类:其他好文   时间:2014-11-14 12:13:30    阅读次数:559
聊聊高并发(十三)实现几种自旋锁(六)
聊聊高并发(十一)实现几种自旋锁(五) 给出了限时有界队列锁的lock和unlock实现,这篇给出tryLock的实现 tryLock比lock稍微复杂一点,要处理超时的情况。超时有几种情况: 1. 第一步在等待队列还没有获得节点的时候超时,直接返回false即可 2. 第二步在等待队列已经获得节点但是还没有加入工作队列时超时,把节点状态可以直接改成FREE给后续线程使用,然后返回f...
分类:其他好文   时间:2014-10-30 17:06:48    阅读次数:154
聊聊高并发(十二)分析java.util.concurrent.atomic.AtomicStampedReference源码来看如何解决CAS的ABA问题
在聊聊高并发(十一)实现几种自旋锁(五)中使用了java.util.concurrent.atomic.AtomicStampedReference原子变量指向工作队列的队尾,为何使用AtomicStampedReference原子变量而不是使用AtomicReference是因为这个实现中等待队列的同一个节点具备不同的状态,而同一个节点会多次进出工作队列,这就有可能出现出现ABA问题。...
分类:编程语言   时间:2014-10-30 15:29:14    阅读次数:245
中断下半部-工作队列
工作队列和tasklet的区别;中断上下文;工作队列的使用;为什么还需要工作队列?工作队列(work queue)是另外一种将中断的部分工作推后的一种方式,它可以实现一些tasklet不能实现的工作,比如工作队列机制可以睡眠。这种差异的本质原因是,在工作队列机制中,将推后的工作交给一个称之为工作者线...
分类:其他好文   时间:2014-10-28 19:32:53    阅读次数:240
217条   上一页 1 ... 18 19 20 21 22 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!