public final void wait() throws InterruptedException Causes the current thread to wait until another thread invokes the notify() method or the notifyA ...
分类:
编程语言 时间:
2017-02-04 01:04:39
阅读次数:
219
/* 线程通讯: 一个线程完成了自己的任务时,要通知另外一个线程去完成另外一个任务. 生产者与消费者 wait(): 等待 如果线程执行了wait方法,那么该线程会进入等待的状态,等待状态下的线程必须要被其他线程调用notify方法才能唤醒。 notify(): 唤醒 唤醒线程池等待线程其中的一个。... ...
分类:
编程语言 时间:
2017-02-02 23:50:09
阅读次数:
351
benchmark 分析 组成部分 三个java类,都含有main方法,可选的传递一些参数,诸如测试线程数量,消息体积大小。三个类分别用于测试普通生产者,事务生产者,消费者。生产者 默认64个测试线程 1280byte消息大小。 测试指标 普通生产者 这段时间内 每秒发送成功了多少条 采样时间断内 ...
分类:
其他好文 时间:
2017-02-02 20:49:52
阅读次数:
360
1. 什么是阻塞队列? 阻塞队列(BlockingQueue)是一个支持两个附加操作的队列。这两个附加的操作是:在队列为空时,获取元素的线程会等待队列变为非空。当队列满时,存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景,生产者是往队列里添加元素的线程,消费者是从队列里拿元素的线程。 ...
分类:
编程语言 时间:
2017-02-01 14:53:51
阅读次数:
414
什么是阻塞队列? 阻塞队列(BlockingQueue)是一个支持两个附加操作的队列。这两个附加的操作是:在队列为空时,获取元素的线程会等待队列变为非空。当队列满时,存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景,生产者是往队列里添加元素的线程,消费者是从队列里拿元素的线程。阻塞队 ...
分类:
编程语言 时间:
2017-01-24 17:19:45
阅读次数:
229
简介 Dubbo是一个来自阿里巴巴的开源分布式服务框架,当当根据自身的需求,为Dubbo实现了一些新的功能,包括REST风格远程调用、Kryo/FST序列化等等。并将其命名为Dubbox(即Dubbo eXtensions),教程一就写生产者,教程二就写消费者 一、生产者工程结构 二、Simple. ...
分类:
其他好文 时间:
2017-01-23 22:42:51
阅读次数:
337
推荐系统 1.缘起 糖豆作为国内最大的广场舞平台,全网的MAU已经超过4000万,每月PGC和UCG生产的视频个数已经超过15万个,每月用户观看的视频也超过100万个。然而之前糖豆APP首页主要还是依赖内容编辑手工推荐来发现内容,每天的推荐量也是几十个而已。明显可见千人一面的内容分发效率比较低下,继 ...
分类:
其他好文 时间:
2017-01-21 21:21:33
阅读次数:
907
ActiveMQ的另一种模式就SUB/HUB即发布订阅模式,是SUB/hub就是一拖N的USB分线器的意思。意思就是一个来源分到N个出口。还是上节的例子,当一个订单产生后,后台N个系统需要联动,但有一个前提是都需要收到订单信息,那么我们就需要将一个生产者的消息发布到N个消费者。 生产者: 假设生产者 ...
分类:
其他好文 时间:
2017-01-17 15:20:28
阅读次数:
197
阅读目录 什么是Java消息服务 为什么需要JMS JMS的优势 JMS消息传送模型 接收消息 JMS编程接口 JMS消息结构 JMS使用示例 译文链接(做了部分修改~~) 阅读目录 什么是Java消息服务 为什么需要JMS JMS的优势 JMS消息传送模型 接收消息 JMS编程接口 JMS消息结构 ...
分类:
编程语言 时间:
2017-01-14 18:43:25
阅读次数:
255
创建一个web工程 导入ActiveMQ依赖的jar包 activemq-all-5.9.jar 写一个生产者(send)servlet package com.sun.jms;import java.io.IOException;import java.io.PrintWriter; import ...
分类:
其他好文 时间:
2017-01-14 18:24:47
阅读次数:
191