private static ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 10L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(500),
new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r);
thread.setName("submit-execute-test");
return thread;
private static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss SSS");
public static void main(String[] args) {
Random random = new Random();
for (int i = 0; i < 10; i++) {
int j = i;
executor.execute(new Runnable() {
@Override
public void run() {
try {
TimeUnit.SECONDS.sleep(2 + random.nextInt(5));
} catch (InterruptedException e) {
e.printStackTrace();
if (j % 2 != 0) {
throw new RuntimeException("线程错误");
LinkedBlockingQueue
queue = (LinkedBlockingQueue) executor.getQueue();
System.out.println(formatter.format(LocalDateTime.now()) + "::" + Thread.currentThread().getName() + "::" +
"核心线程数 :" + executor.getCorePoolSize() +
"::最大线程数 :" + executor.getMaximumPoolSize() +
"::活动线程数 :" + executor.getActiveCount() +
"::任务完成数" + executor.getCompletedTaskCount() +
"::队列使用 :" + queue.size() + "::队列未使用 :" + queue.remainingCapacity() + "::队列总共大小 :" + (queue.size() + queue.remainingCapacity()));
从打印中可以看到当execute提交runable的时候异常会输出。
2、我们将execute 换成submit ,其他都不变,再次查看运行情况
可以看出除了我们在代码里面输出内容并未抛出异常。
查看ThreadPoolExecutor 的submit方法,是将Runable方法进行封装,再交给Executor去execute,这个方法和ThreadPoolExecutor 的execute方法一样
public Future<?> submit(Runnable task) {
if (task == null) throw new NullPointerException();
RunnableFuture<Void> ftask = newTaskFor(task, null);
execute(ftask);
return ftask;
newTaskFor 方法是创建FutureTask 对象,那么具体不抛异常应该就在FutureTask的run方法了。
protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {
return new FutureTask<T>(runnable, value);
FutureTask 的run方法,在run方法中对Throwable 异常进行捕获,错误的时候将异常设置到返回结果。执行正常结束,将返回结果set到结果中
public void run() {
if (state != NEW ||
!UNSAFE.compareAndSwapObject(this, runnerOffset,
null, Thread.currentThread()))
return;
try {
Callable<V> c = callable;
if (c != null && state == NEW) {
V result;
boolean ran;
try {
result = c.call();
ran = true;
} catch (Throwable ex) {
result = null;
ran = false;
//设置异常到返回结构中
setException(ex);
//执行正确结束设置返回结果
if (ran)
set(result);
} finally {
// runner must be non-null until state is settled to
// prevent concurrent calls to run()
runner = null;
// state must be re-read after nulling runner to prevent
// leaked interrupts
int s = state;
if (s >= INTERRUPTING)
handlePossibleCancellationInterrupt(s);
根据上面的分析,如果ThreadPoolExecutor 提交任务的时候如果并不关心返回结果最好直接使用ThreadPoolExecutor.execute() 方法。
D .无须区别,统一在业务代码中进行判断和识别。
多选 2.关于并发处理,下列哪些说法符合《阿里巴巴Java开发手册》:ABC
A .线程资源必须通过线程池提供,不允许在应用中自行显式创建线程。
B .同步处理时,能锁部分代码区块的情况下不要锁整个方法;高并发时,同步调用应该考虑到性能损耗。
C .创建线程或线程池时,推荐给线程指定一个有意义的名称,方便出错时回溯。
D .推荐使用Executors.newFixedThreadPool(int x)生成指定大小的线程池。(线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式)
多选 3.下列哪些说法符合《阿里巴巴Java开发手册》:ACD
A .对于“明确停止使用的代码和配置”,如方法、变量、类、配置文件、动态配置属性等要坚决从程序中清理出去,避免造成过多垃圾。
B .永久弃用的代码段注释掉即可,即不用加任何注释。
C .对于暂时被注释掉,后续可能恢复使用的代码片断,在注释代码上方,统一规定使用三 个斜杠(///)来说明注释掉代码的理由。
D .不要在视图模板中加入任何复杂的逻辑。
多选 4.关于分页查询,下列哪些说法符合《阿里巴巴Java开发手册》:ABC
A .分页查询,当统计的count为0时,应该直接返回,不要再执行分页查询语句。
B .iBATIS自带的queryForList(String statementName,int start,int size)分页接口有性能隐患,不允许使用。
C .定义明确的sql查询语句,通过传入参数start和size来实现分页逻辑。
D .可使用存储过程写分页逻辑,提高效率。
多选 5.根据《阿里巴巴Java开发手册》,以下功能必须进行水平权限控制校验的有:ABCD
A .订单详情页面。
B .类目管理后台。
C .店铺装修后台。
D .订单付款页面。
多选 6.关于数据库中NULL的描述,下列哪些说法符合《阿里巴巴Java开发手册》:BD
A .NULL=NULL的返回结果为true。
B .NULL与任何值的比较结果都为NULL。
C .NULL<>1的返回结果为true。
D .当某一列的值全是NULL时,sum(col)的返回结果为NULL。
多选 7.关于接口使用抛异常还是返回错误码,下列哪些说法符合《阿里巴巴Java开发手册》:ABCD
A .向公司外部提供的http/api接口,推荐使用“错误码”方式返回异常或者错误信息。
B .对于应用内部的方法调用,推荐使用“抛出异常”的方式处理异常或者错误信息。
C .跨应用的RPC调用,推荐使用将“错误码”和“错误简短信息”封装成Result的方式进行返回。
D .对外提供的接口,一定要保证逻辑健壮性:尽量避免空指针等技术类异常;对于业务类异常要做好错误码或者异常信息的封装。
单选 8.关于类的序列化,下列说法哪些是正确的:D
A .类的序列化与serialVersionUID毫无关系。
B .如果完全不兼容升级,不需要修改serialVersionUID值。
C .POJO类的serialVersionUID不一致会编译出错。
D .POJO类的serialVersionUID不一致会抛出序列化运行时异常。
多选 9.关于Java的接口描述,下列哪些说法符合《阿里巴巴Java开发手册》:BCD
A .在接口类中的方法和属性使用public修饰符。
B .对于Service类,内部的实现类加Impl的后缀与接口区别。例如:ProductServiceImpl实现ProductService接口。
C .对于Service类,基于SOA的理念,是以接口方式暴露服务。
D .尽量不在接口里定义变量,如果一定要定义变量,肯定是与接口方法相关,而且是整个应用的基础常量。
单选 10.集合在遍历过程中,有时需要对符合一定条件的元素进行删除,下列哪些说法是正确的:B
A .在 foreach 循环里进行元素的 remove操作。
B .使用Iterator方式,如果有并发,需要对Iterator对象加锁。
C .Iterator进行元素的删除操作,绝对是线程安全的。
D .Java无法实现在遍历时,进行删除元素操作。
多选 11.关于基本数据类型与包装数据类型的使用标准,下列哪些说法符合《阿里巴巴Java开发手册》:ABD
A .所有的POJO类属性必须使用包装数据类型。
B .RPC方法的返回值和参数必须使用包装数据类型。
C .因为JAVA的自动装箱与拆箱机制,不需要根据场景来区分数据类型。
D .所有的局部变量推荐使用基本数据类型。
多选 12.关于索引的设计,下列哪些说法符合《阿里巴巴Java开发手册》:ACD
A .对varchar类型的字段建立索引,必须指定索引长度。
B .对varchar类型的字段建立索引,不需要指定索引长度,这样索引区分度最好。
C .业务上具有唯一特性的字段(含组合字段),必须指定唯一索引。
D .建复合索引时,一般选择区分度高的字段放在最左列。
多选 13.关于二方库版本号的命名方式,下列哪些说法符合《阿里巴巴Java开发手册》:ABCD
A .版本号命名格式:主版本号.次版本号.修订号。
B .主版本号:产品方向改变,或者大规模API不兼容,或者架构不兼容升级。
C .次版本号:保持相对兼容性,增加主要功能特性,影响范围极小的API不兼容修改。
D .修订号:保持完全兼容性,修复BUG、新增次要功能特性等。
多选 14.关于索引的使用,下列哪些说法是正确的:BCD
A .查询语句 WHERE a+1 = 5 可以利用a索引。
B .查询语句WHERE date_format(gmt_create, '%Y-%m-%d') = '2016-11-11'无法利用gmt_create索引。
C .当 c 列类型为 char 时,查询语句 WHERE c = 5 无法利用c索引。
D .索引字段使用时不能进行函数运算。
多选 15.关于生产环境的日志文件,下列哪些说法符合《阿里巴巴Java开发手册》:ABCD
A .异常信息应该包括两类信息:案发现场信息和异常堆栈信息。
B .日志文件推荐至少保存15天,因为有些异常具备以“周”为频次发生的特点。
C .避免重复打印日志,浪费磁盘空间,务必在log4j.xml中设置additivity=false。
D .错误日志和业务日志尽量分开存放。
多选 16.关于代码注释,下列哪些说法符合《阿里巴巴Java开发手册》:ABD
A .特殊注释标记,请注明标记人与标记时间。
B .待办事宜(TODO):( [标记人,标记时间,[预计处理时间])
C .在注释中用FIXME标记某代码虽然实现了功能,但是实现的方法有待商榷,希望将来能改进
D .在注释中用FIXME标记某代码是错误的,而且不能工作,需要及时纠正的情况
多选 17.关于MySQL性能优化的描述,下列哪些说法是正确的:ABCD
A .主键查询优先于二级索引查询。
B .表连接有一定的代价,故表连接数量越少越好。
C .一般情况下,二级索引扫描优先于全表扫描。
D .可以使用通过索引避免排序代价。
多选 18.关于索引的设计和使用,下列哪些说法是正确的:AD
A .若查询条件中不包含索引的最左列,则无法使用索引。
B .对于范围查询,只能利用索引的最左列。
C .对于order by A或group by A语句,在A上建立索引,可以避免排序。
D .对于多列排序,需要所有所有列排序方向一致,才能利用索引。
多选 19.关于类命名,下列哪些说法符合《阿里巴巴Java开发手册》:ABCD
A .抽象类命名使用Abstract或Base开头。
B .异常类命名使用Exception结尾。
C .测试类命名以它要测试的类的名称开始,以Test结尾。
D .如果使用到了设计模式,建议在类名中体现出具体模式。例如代理模式的类命名:LoginProxy;观察者模式命名:ResourceObserver。
多选 20.关于数据库模糊检索的描述,下列哪些说法符合《阿里巴巴Java开发手册》:ABD
A .绝对禁止左模糊。
B .绝对禁止全模糊。
C .绝对禁止右模糊。
D .全模糊或左模糊查询需求,优先使用搜索引擎。
多选 21.关于代码注释,下列哪些说法符合《阿里巴巴Java开发手册》:ACD
A .所有的抽象方法(包括接口中的方法)必须要用javadoc注释。
B .所有的方法,包括私有方法,最好都增加注释,有总比没有强。
C .过多过滥的注释,代码的逻辑一旦修改,修改注释是相当大的负担。
D .我的命名和代码结构非常好,可以减少注释的内容。
多选 22.关于checked/unchecked exception,下列哪些说法是正确的:BCD
A .继承java.lang.Error的类属于checked exception。
B .checked异常继承java.lang.Exception类。
C .unchecked异常继承java.lang.RuntimeException类。
D .NullPointerException , IllegalArgumentException属于unchecked exception。
单选 23.关于Map类型集合的遍历方式,下列哪些说法是正确的:D
A .Map类型的实现类都同时实现了Iterator接口。
B .使用foreach进行遍历。
C .推荐使用keySet进行遍历。
D .推荐使用entrySet进行遍历。
多选 24.关于变量、方法名、包的命名,下列哪些说法符合《阿里巴巴Java开发手册》:ABCD
A .POJO类中的任何布尔类型的变量,都不要加is,因为部分框架解析时有可能会出现序列化错误。
B .包名统一使用单数形式,如:com.alibaba.mpp.util。
C .中括号是数组类型的一部分,数组定义如下:String[] args; 不要误写为String args[];
D .Service/DAO层方法命名可以参考规约,例如:删除的方法推荐使用remove或delete做前缀。
多选 25.关于常量定义,下列哪些说法符合《阿里巴巴Java开发手册》:AC
A .不允许出现任何魔法值(即未经预先定义的常量)直接出现在代码中。
B .魔法值是指程序中随意定义并赋值的变量值,如果代码编写者明白变量值意义是可以任意使用的,例如在代码中写if(status == 3) return error;符合规范。
C .如果变量值仅在一个范围内变化推荐用Enum类。
D .在程序中,一律禁止使用枚举类型。
多选 26.关于maven依赖、仲裁、规则,下列哪些说法是正确的:ACD
A .<dependencies>的依赖会默认传递给子项目。
B .<dependencies>的依赖绝对不会传递给子项目。
C .在<dependencyManagement>中指定版本号。
D .避免在不同的子项目,声明同一个二方库的不同版本号。
单选 27.关于二方库升级,下列哪些说法是正确的:B
A .升级二
我的解决方案非常简单,就是自己写一个类继承java.util.concurrent.ThreadPoolExecutor,然后重写里面的几个方法如下public class ThreadPoolExecute extends ThreadPoolExecutor {public ThreadPoolExecute(int corePoolSize, int maximumPoolSize, lon...
接下来我们来看一下java中的线程池是如何运行我们提交的任务的,详细流程比较复杂,这里我们不关注,我们只关注任务执行的部分。java中的线程池用的是ThreadPoolExecutor,真正执行代码的部分是runWorker方法:final
void runWork
在使用异步CompletableFuture时,无论是否有返回值都要调用get()/join()方法,避免程序执行报错了,仍然返回成功。如果在程序报错时需要对上一个异步任务结果做其他操作,可以调用whenComplete()、handle()处理,如果只是对异常做处理,不涉及对上一个异步任务结果的情况,调用exceptionally()处理。
单元测试不支持在多线程下使用单元测试中程序的结束是以主线程为主的debug会延长运行时间多线程测试建议直接在main方法中进行参考文章单元测试使用多线程的情况Junit单元测试不支持多线程测试–原因分析和问题解决Java单例7种测试实践在此致谢。
submit执行时,因为callable类会被转成FutureTask类,FutureTask的run方法中捕获了异常,所以就不会抛出异常。解决办法手动调用FutureTask的get方法,get方法中会抛出outcome异常。execute执行时 task.run()方法,出现异常会直接抛出。(线程池每添加一个线程,就会在worker中添加一个)(Runnable run)日志信息可以正常打印。(callable call)不会打印日志信息。
利用ThreadPoolExecutor提交线程任务的时候,在线程里面发生异常,不会被主线程所捕抓,而是消无声息地死亡,非常不便于调试,尤其在我们写gui程序的时候。
我们可以新增一条线程帮我们把异常打印出来。
import time, traceback
from concurrent.futures import ThreadPoolExecutor
from concurrent.futur...
项目中碰到一个问题,scheduleAtFixedRate起了一个定时循环的任务,发现这个任务终止了,但是又没有相关日志提示,本文得出一个结论:
当某次执行该任务,若出现异常且没有try catch,不会打印任务异常日志,并且会终止后续的任务
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledEx...
问题是这样的,弄了个类,实现runnable接口,然后,就刷刷刷的初始化了n个线程,然后通过ThreadPoolExecutor提交到线程池中运行,期望是这个run一直不停的执行,起初一切都很正常。然后就遇到了问题。分两个阶段。
第一个阶段:初级阶段。
线程的run方法在执行的,因为种种原因,出现了异常,然后,这个线程就直接GG了,导致当初提交的n个线程中出现异常的就没了,导致了问题,虽然出问题了,但是,起码还能在日志中看到错误信息,有迹可循,慢慢的排查问题,完善代码,尽量降低他异常的概率,接近于零吧。