ListenableFuture是可以监听的Future，它是对java原生Future的扩展增强。Future表示一个异步计算任务，当任务完成时可以得到计算结果。如果希望计算完成时马上就拿到结果展示给用户或者做另外的计算，就必须使用另一个线程不断的查询计算状态。这样做会使得代码复杂，且效率低下。如果使用ListenableFuture，Guava会帮助检测Future是否完成了，如果完成就自动调用回调函数，这样可以减少并发程序的复杂度。
阅读全文
Lock是java.util.concurrent.locks包下的接口，Lock 实现提供了比使用synchronized 方法和语句可获得的更广泛的锁定操作，它能以更优雅的方式处理线程同步问题。
阅读全文
java线程有两个重要的特性，可见性和有序性，多个线程之间是不能直接传递数据的，它们之间的交互只能通过共享变量实现。例如，对一堆数据进行求和运算，多个线程共享一个Sum类的对象，这个对象是被创建在主内存(堆)中，每个线程都有自己的工作内存(线程栈)，工作内存存储了Sum对象的一个副本，当线程操作Sum对象时，首先从主内存中复制Sum对象到工作内存中，然后执行方法求和，改变sum值，最后用工作内存的Sum对象刷新主内存的Sum对象，当一个对象在多个线程中都有Sum对象的副本时，如果其中一个线程修改了共享变量，其它线程也应该能看见到，这是可见性。因为CPU对线程的调度是随机性的，在处理一些业务如银行转账时，必须保证先取款后汇款或先汇款后取款的有序操作，这是有序性。
阅读全文
JDK1.5以后java加入了一个并发包java.util.concurrent用于替换传统的多线程使用场景。其中包含几个重要的接口Executor,ExecutorService,Future,Callable等。
Executor接口只定义了一个方法void execute(Runnable command),它用来执行提交的任务，用户只需提交任务，不必关心任务何时执行以及任务的调度情况。用户不需要明确的像传统方式那样定义一个线程，如：new Thread(new(RunnableTask())).start()。可以通过如下方式提交一个任务
阅读全文
log4j2相对于log4j1.x有了相当大的变换，官方称相对于log4j，在多线程下高达10多倍的吞吐量。在之前的项目中一直使用的是log4j1.x，这次需要升级到log4j2，以前的自定义的日志级别如输出接口访问信息到指定文件就需要更改。
阅读全文最近的一个需求，需要记录接口访问的详情，如请求入参、出参、请求上下文、路径、消耗时间以及成功失败等信息，将这些信息以结构化的形式输出到单独的日志文件中，方便以后入库到elasticsearch中做分析。
百度搜索自定义日志级别的文章一大把，基本上都是使用Filter和xml配置的方式，这种方式能行，但我感觉写的代码略多，而且我的工程中用的properties的方式配置的，个人也比较懒也就不想改动，就没有采用这种方式。
log4j中每个appenders都有一个threshold，这个值默认是null，它对应的是配置文件中log4j.appender.errorfile.Threshold = debug|info|error|...项，如果不配置，会将所有级别日志打印到这个appender中，如果是debug则会将debug及以上的级别日志打印到这个appender中。
阅读全文
DataX 是一个异构数据源离线同步工具，致力于实现包括关系型数据库(MySQL、Oracle等)、HDFS、Hive、MaxCompute(原ODPS)、HBase、FTP等各种异构数据源之间稳定高效的数据同步功能。
datax-elasticsearch是datax的一个支持elasticsearch的插件，包含elasticsearchreader和elasticsearchwriter两部分。借助于datax体系，能够高效的在elasticsearch与oracle、mysql、HDFS等异构数据源间同步数据。
阅读全文