Java5新增的并发包的部分源码的解读系列第一篇。
分类：
其他好文 时间：
2015-07-06 06:38:22
阅读次数：
184
本文简要介绍了Java多线程中的Executor框架，包括Runnable、Callable、Future、RunnableFuture、FutureTask、Executor、ExecutorService以及这些接口与类之间的关系。...
分类：
编程语言 时间：
2015-07-05 09:34:54
阅读次数：
184
WO想要Executor线程池，WO还想要限制线程池大小，WO还想要线程闲置超时能自动销毁。 好的～ ThreadPoolExecutor?mThreadPool?=?new?ThreadPoolExecutor(poolSize,?0,?maxIdleTime,?TimeUnit.SECONDS,?Lin...
分类：
编程语言 时间：
2015-07-04 17:02:32
阅读次数：
226
Storm 配置图文解析. 一个worker进程(process)会产生N个线程(executor)，那么并行度(parallelism)就是所有线程的数目。setNumWorkers
任务(task)是线程执行的工作队列，线程的任务数说明线程的吞吐能力。一个线程的各个任务之间并不是并发的。setNumTasks
线程(executor)是执行任务的上下文环境。...
分类：
其他好文 时间：
2015-07-01 12:16:37
阅读次数：
128
上一篇讲了Executor接口的设计，目的是将任务的执行和任务的提交解耦，可以隐藏任务的执行策略。这篇说说ExecutorService接口。它扩展了Executor接口，对Executor的生命周期进行管理，并进行了进一步的扩展。
Executor负责执行任务。它的生命周期有3个：运行，关闭和已终止。在运行的任何时刻，有些 任务可能已经完成，有些可能正在运行，有些可能正在队列中等待执行...
分类：
编程语言 时间：
2015-06-27 10:08:27
阅读次数：
154
Java里面线程池顶级接口是Executor，但严格意义上讲Executor并不是一个线程池，而是一个线程执行工具，真正的线程池接口是ExecutorService.关系类图如下： 首先Executor的execute方法只是执行一个Runnable任务而已，当然从某种角度上讲最后的实现类...
分类：
其他好文 时间：
2015-06-26 21:08:10
阅读次数：
157
1、保证spark-sql已经使用mysql作为metadata存储介质2、启动thrift网关$SPARK_HOME/sbin/start-thriftserver.sh--driver-class-path
/usr/local/spark/spark-1.3.0-bin-hadoop2.3/lib/mysql-connector-java-5.1.6-bin.jar
--masterspark://hd1:7077--executor-memory2g--total-..
分类：
其他好文 时间：
2015-06-23 23:23:32
阅读次数：
888
出现这个问题，是因为spark的excutor执行的时候，缺少hive的依赖包，添加依赖包的参数是：--conf "spark.executor.extraClassPath=/opt/cloudera/parcels/CDH-5.3.1-1.cdh5.3.1.p0.5/lib/hive/lib/*...
分类：
数据库 时间：
2015-06-23 13:30:45
阅读次数：
337
一?线程池 2.1?线程池相关类结构 Executor ? ? ??ExecutorService ? ? ? ? ? ??AbstractExecutorService ? ? ? ? ? ? ? ? ? ?ThreadPoolExecutor 2.2?各个类介绍 2.2.1?接口Executor??...
分类：
编程语言 时间：
2015-06-19 09:02:53
阅读次数：
165
（一）storm拓扑的并行度可以从以下4个维度进行设置：1、node（服务器）：指一个storm集群中的supervisor服务器数量。2、worker（jvm进程）：指整个拓扑中worker进程的总数量，这些数量会随机的平均分配到各个node。3、executor（线程）：指某个spout或者bo...
分类：
其他好文 时间：
2015-06-17 13:18:10
阅读次数：
152
