1. 什么是阻塞队列？ 阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。 ...
分类：
编程语言 时间：
2017-01-05 18:14:15
阅读次数：
432
一、概述 disruptor对于处理并发任务很擅长，曾有人测过，一个线程里1s内可以处理六百万个订单，性能相当感人。 这个框架的结构大概是：数据生产端 --> 缓存 --> 消费端 缓存中的数据是主动发给消费端的，而不是像一般的生产者消费者模式那样，消费端去缓存中取数据。 可以将disruptor理 ...
分类：
其他好文 时间：
2017-01-05 13:37:53
阅读次数：
458
spring-amq.xml 生产者 消费者 如果是topic的话就换一下 在测试的时候可以不需要写消费者的代码，因为我们要么是生产者要么是消费者 可以通过配置一个listener来实现 不需要写消费者的代码就可以知道消息有没有推送成功 ...
分类：
编程语言 时间：
2017-01-03 22:26:45
阅读次数：
388
题目：现在两个线程，可以操作同一个变量，实现一个线程对该变量加1，一个线程对该变量减1，实现交替，来10轮，变量初始值为零。 在这个需要注意一个问题在共享对象的方法里 将if替换为while，解决虚假唤醒的问题。 ...
分类：
编程语言 时间：
2017-01-03 20:22:51
阅读次数：
168
线程互斥锁和条件等待解决生产者和消费者模型 ...
分类：
编程语言 时间：
2017-01-01 18:57:26
阅读次数：
173
一、目录结构 相关jar包 二、关键配置activmq.xml 三、关键代码 1、生产者 1.1 点对点生产者 1.2 发布订阅生产者 2、消费者 2.1点对点消费者 2.2发布订阅消费者 参考： http://blog.csdn.net/jiuqiyuliang/article/details/4 ...
分类：
编程语言 时间：
2016-12-30 02:23:11
阅读次数：
256
package de.bvb; /** * 生产者消费者模式 * 通过 wait() 和 notify() 通信方法实现 * */ public class Test1 { public static void main(String[] args) { Godown godown = new Go... ...
分类：
编程语言 时间：
2016-12-28 20:10:05
阅读次数：
199
报错： 查看当前主机名： hostname命令： 在hosts中配置mq的master和slave（如果有slave）： 这样生产者服务就可以启动了。 ...
分类：
其他好文 时间：
2016-12-28 12:03:34
阅读次数：
438
任务调度:1.Celery默认任务单元由任务生产者触发,但有时可能需要其自动触发,而Beat进程正是负责此类任务,能够自动触发定时/周期性任务.#!/usr/bin/envpython
#-*-coding:utf-8-*-
#@Date:2016-12-2417:32:54
#@Author:李满满(xmdevops@vip.qq.com)
#@Link:http://xmdevops.blog..
分类：
编程语言 时间：
2016-12-28 02:38:08
阅读次数：
190
rabbitMQ实战(一) 使用pika库实现hello world 2016-05-18 23:29 本站整理 浏览(267) pika是RabbitMQ团队编写的官方Python AMQP库。需要先安装pika:pip3 install pika有较详细的注释，就不再详细说明了生产者代码：hel ...
分类：
其他好文 时间：
2016-12-26 21:13:17
阅读次数：
572
