===>?什么是?Storm?????????-->?Twitter将Storm正式开源了,这是一个分布式的、容错的实时计算系统,遵循 Eclipse Public License 1.0。? ? ????-->
分类:
其他好文 时间:
2018-02-01 17:20:43
阅读次数:
228
1. 描述 基于Jetty-9.4.8.v20171121。 Connector接受远程机器的连接和数据,允许应用向远程机器发送数据。 1.2 类图 从类图看出AbstractConnector继承ContainerLifeCycle,所以具有Container和LifeCycle特性。 此外有一个 ...
分类:
其他好文 时间:
2018-01-27 19:10:18
阅读次数:
162
一、线程池状态 RUNNING : 该状态的线程池会接收新的任务,并处理阻塞队列中的任务。 SHUTDOWN : 该状态的线程池不会接收新的任务,但会处理阻塞队列中的任务。 STOP : 该状态的线程池不会接收新的任务,也不会处理阻塞队列中的任务,而且会中断正在执行的任务。 二、任务提交 方式 1、 ...
分类:
编程语言 时间:
2018-01-25 23:15:18
阅读次数:
360
一、背景 线程属于系统稀缺资源,在使用线程时,如果无限制创建线程,达到CPU高负荷时,会导致系统运行缓慢,更有甚者直接宕机。 在这样的基础上我们希望在使用线程时,竟可能使系统线程数处于一个可控范围,尽可能实现线程的重用。 二、Executors 分析 Executors 示例 DEMO 示例分析: ...
分类:
编程语言 时间:
2018-01-25 00:32:44
阅读次数:
199
Java.util.concurrent.locks包提供了一个包含多种接口和类的框架,它针对条件进行加锁和等待。不同于对象的内置加锁同步以及java.lang.Object的等待/通知机制,包含锁框架的并发工具类通过轮询锁、显示等待及其它方式改善这种机制。锁框架包含了经常使用的锁、重入锁、条件、读写锁以及冲入读写锁等类别。一、锁Lock实现提供了比使用synchronized方法和语句可获得的更
分类:
编程语言 时间:
2018-01-21 19:02:54
阅读次数:
235
```java package bjsxt.curator.base; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import ... ...
在一些不需要实时更新统计的业务时,可以将方法调用改为异步执行。 private static ExecutorService service = Executors.newCachedThreadPool(); service.execute(new Runnable() { @Override p ...
分类:
编程语言 时间:
2018-01-11 16:04:23
阅读次数:
219
第一种:循环执行的程序 import java.text.SimpleDateFormat;import java.util.Date;import java.util.concurrent.Executors;import java.util.concurrent.ScheduledExecuto ...
分类:
编程语言 时间:
2018-01-05 12:27:59
阅读次数:
136
1、spark on yarn作业提交(yarn-client模式) bin/spark-submit \--class dajiangtai.averageAge \--master yarn-client \--num-executors 1 \--driver-memory 1g \--exe ...
分类:
其他好文 时间:
2017-12-30 19:03:14
阅读次数:
169
随着cpu核数越来越多,不可避免的利用多线程技术以充分利用其计算能力。所以,多线程技术是服务端开发人员必须掌握的技术。 线程的创建和销毁,都涉及到系统调用,比较消耗系统资源,所以就引入了线程池技术,避免频繁的线程创建和销毁。 在Java用有一个Executors工具类,可以为我们创建一个线程池,其本 ...
分类:
编程语言 时间:
2017-12-30 00:27:44
阅读次数:
195