Concurrent Work

Rambling of a coder who craves for knowledge and understanding of the world.

07 Nov 2014

jdk 1.8 java.util.concurrent.atomic.* 源码阅读

Written by Dongfang Qu
代码 version: 1.8 code path: jdk8u/jdk/src/share/classes/java/util/concurrent/atomic 收获 Atomic* 由 Unsafe实现 Unsafe: 声明一些native方 …
30 Oct 2014

storm bolt单元测试方法

Written by Dongfang Qu
根据自己做storm bolt单元测试的经验，写了几个常见的例子。 其中主要使用mockito，也试着试用了下backtype.storm.testing测试框架，在我看来storm.testing框架功能很有限，用起来很不爽，可能自己太笨吧！ 暂时把代码github放出来，有空 …
25 Oct 2014

2014读书单

Written by Dongfang Qu
今年读的几本书 人文 一个人的圣经 影响力 金阁寺 美丽新世界 科技 黑客与画家 The logstash Book Java Quick Syntax Reference Getting Started with Storm 了不起的Node.js …
15 Sep 2014

关闭kafka java api的log4j配置提升kafka producer性能

Written by Dongfang Qu
背景 前段时间由于项目需要，基于官方提供的kafka 0.8.1.1版java api开发一个thrift接口的kafka代理层模块，我们暂且就称它为kafka-proxy吧， 主要功能是通过thrift接口接收外部系统的数据，根据规则转发给后端不同的kafka topic。 问 …
14 Jul 2014

jetty 9运行在jdk1.6时假死问题

Written by Dongfang Qu
代码 package com.baidu.oped.aqueducts.server.status; import org.eclipse.jetty.server.Server; import org.apache.logging.log4j.LogManager; …