异常捕获以前使用executor的时候，为了记录任务线程的异常退出会使用ThreadFactory来设置线程的UncaughtExceptionHandler，但是按照书上的验证发现，采用executorService.submit执行任务时，线程抛出的异常并不会被该处理器捕获，而当使用execut...
分类：
编程语言 时间：
2015-03-07 22:30:36
阅读次数：
145
问题简述： 配置的队列初始化的消费者线程占满了线程池。导致其他的再使用此线程池中线程不运行。不报错，不抛异常。线程的数量仅为为线程池的配置中的最小值。 <task:executor pool-size="100-150" queue-capac...
分类：
编程语言 时间：
2015-03-06 17:30:55
阅读次数：
208
TaskSetManager.scalaTaskSet是指一系列被提交的task，一般是代表特定的stage中丢失的partition。TaskSetManager通过一个TaskSchedulerImpl实体来对TaskSet进行管理。该方法定义了以下参数：EXECUTOR_TASK_BLACKL...
分类：
其他好文 时间：
2015-03-05 16:21:14
阅读次数：
156
JDK1.5之后，提供了自带的线程池，以便我们更好的处理线程并发问题。Executor类给我提供了多个线程池创建的方式： 创建固定的线程池Executors.newFixedThreadPool(2) 创建可变的缓冲线程池Executors.newCachedThreadPool() 创建单一的线程...
分类：
编程语言 时间：
2015-02-26 11:35:37
阅读次数：
162
这是我从网上收集的常见Java面试题及答案，但只收录了我不会做的题目。创建线程有几种不同的方式？你喜欢哪一种？为什么？有三种方式可以用来创建线程：继承Thread类实现Runnable接口应用程序可以使用Executor框架来创建线程池实现Runnable接口这种方式更受欢迎，因为这不需要..
分类：
编程语言 时间：
2015-02-20 00:14:51
阅读次数：
393
背景
主体逻辑
具体实现
AM
YarnAllocator
Executor背景Spark on Yarn分yarn-cluster和yarn-client两种模式。
本文通过Cluster模式的TaskScheduler实现入手，梳理一遍spark on yarn的大致实现逻辑。
前提我对两种模式以及yarn任务的整体运行逻辑不是很清楚。
主体逻辑cluster模式中，使用的TaskSche...
分类：
其他好文 时间：
2015-02-15 18:06:53
阅读次数：
215
在做一个 JSR 315 - servlet 规范 3.0 的报告时，我意识到理解异步 servlet 的一个关键点在于首先要理解 Java 中的异步处理机制。有因有果，很快我陷入了执行器(Executor)和执行器服务(ExecutorService)之中 - 因为它们是 Java 的异步处理的关键构件。在本博客中我将就这一主题我对掌握到的东西做一个总结。几个概念任务：定义为一个小的独立的活动，...
分类：
编程语言 时间：
2015-02-12 18:32:58
阅读次数：
159
WITH TMP_EXECUTOR(EXECUTOR,EXECUTORNAME) AS ( SELECT DISTINCT T.EXECUTOR ,T1.FULLNAME AS EXECUTORNAMEFROM (SELECT DISTINCT T1.TASKID , T2.EXE...
分类：
其他好文 时间：
2015-02-09 21:32:12
阅读次数：
151
How to monitor server memory usage with Nagios Remote Plugin Executor (NRPE)Last updated on September 8, 2014 Authored by Sarmed Rahman 5 Comments In ...
分类：
移动开发 时间：
2015-02-09 17:33:00
阅读次数：
240
Semaphore用于保证至多只有确定X条线程同时执行，系统在它们之间进行切换下面是一个使用例子package com.condition;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executor...
分类：
编程语言 时间：
2015-02-08 19:27:25
阅读次数：
151
