官方网站 建设情况汇报,河南响应式建站,西安网站建设哪些公司好,桂林网站开发m0773问题
今天在测试环境通过线程池执行任务时突然被中断#xff0c;跟踪日志发现代码跑到一半后面的日志就不再打印#xff0c;而且也没有任何异常堆栈信息#xff0c;也就是说程序执行被中断了#xff0c;后面反复尝试经排查发现是线程池使用不当导致。 测试验证
我们用线程…问题
今天在测试环境通过线程池执行任务时突然被中断跟踪日志发现代码跑到一半后面的日志就不再打印而且也没有任何异常堆栈信息也就是说程序执行被中断了后面反复尝试经排查发现是线程池使用不当导致。 测试验证
我们用线程池执行任务一般有两种方式一种是不需要返回结果的调用execute方法一种是需要返回结果的调用submit方法。
excute方法测试 调用executor方法执行线程不会吃掉异常
Test
public void test0() {ExecutorService executorService Executors.newFixedThreadPool(1);executorService.execute(() - {System.out.println(子线程-begin);System.out.println(1 / 0);System.out.println(子线程-end);});System.out.println(主线程执行完成);
}运行结果如下有异常堆栈信息
主线程执行完成
子线程-begin
Exception in thread pool-1-thread-1 java.lang.ArithmeticException: / by zeroat com.zhouyong.practice.executor.ExecutorTest.lambda$test0$0(ExecutorTest.java:20)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:748)Process finished with exit code 0submit方法测试 线程池中的异常被吃掉-通过submit执行
Test
public void test1() {ExecutorService executorService Executors.newFixedThreadPool(1);executorService.submit(() - {System.out.println(子线程-begin);System.out.println(1 / 0);System.out.println(子线程-end);});System.out.println(主线程执行完成);}执行结果如下没有异常堆栈信息异常被吃掉
子线程-begin
主线程执行完成Process finished with exit code 0结论
调用线程池的submit方法执行线程时异常处理的两种方式
直接在线程run方法内部catch异常自行处理
Test
public void test2(){ExecutorService executorService Executors.newFixedThreadPool(1);executorService.submit(() - {try {System.out.println(子线程-begin);System.out.println(1 / 0);System.out.println(子线程-end);} catch (Exception e) {//TODO 此处做日志记录或者打印异常堆栈 e.printStackTrace();}});System.out.println(主线程执行完成);
}运行结果 通过调用submit返回的Future对象做好异常处理
通过调用submit的返回值Future的get方法时会阻塞等待线程执行完成如果有异常会抛出
Test
public void test2() throws ExecutionException, InterruptedException {ExecutorService executorService Executors.newFixedThreadPool(1);Future? future executorService.submit(() - {System.out.println(子线程-begin);System.out.println(1 / 0);System.out.println(子线程-end);});//TODO 调用get方法时会等待线程执行如果有异常会抛出此处可以catch异常做日志记录 //由于get方法会阻塞主线程因此最好也放在线程池中执行调用execute方法即可System.out.println(future.get());System.out.println(主线程执行完成);}运行结果如下
由于feture.get()方法会阻塞主线程因此最好通过线程池执行
Test
public void test4() {ExecutorService executorService Executors.newFixedThreadPool(2);Future? future executorService.submit(() - {System.out.println(子线程-begin);System.out.println(1 / 0);System.out.println(子线程-end);});//由于get方法会阻塞主线程因此最好也放在线程池中执行调用execute方法即可executorService.execute(()- {try {future.get();} catch (Exception e) {//TODO 此处做日志记录或者打印异常堆栈 e.printStackTrace();}});System.out.println(主线程执行完成);
}运行结果如下
