当前位置:首页 > 科技  > 软件

Java线程池中线程异常后:是销毁还是复用

来源: 责编: 时间:2024-06-14 08:52:26 78观看
导读一个线程池中的线程异常了,那么线程池会怎么处理这个线程?需要说明,本文的线程池都是java.util.concurrent.ExecutorService线程池,本文将围绕验证,阅读源码俩方面来解析这个问题。代码验证验证execute提交线程池中测试代

7PQ28资讯网——每日最新资讯28at.com

一个线程池中的线程异常了,那么线程池会怎么处理这个线程?7PQ28资讯网——每日最新资讯28at.com

7PQ28资讯网——每日最新资讯28at.com

7PQ28资讯网——每日最新资讯28at.com

需要说明,本文的线程池都是java.util.concurrent.ExecutorService线程池,本文将围绕验证,阅读源码俩方面来解析这个问题。7PQ28资讯网——每日最新资讯28at.com

7PQ28资讯网——每日最新资讯28at.com

代码验证

验证execute提交线程池中

测试代码:7PQ28资讯网——每日最新资讯28at.com

public class ThreadPoolExecutorDeadTest {    public static void main(String[] args) throws InterruptedException {        ExecutorService executorService = buildThreadPoolExecutor();        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute-exception"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        Thread.sleep(5000);        System.out.println("再次执行任务=======================");        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));    }    public static ExecutorService buildThreadPoolExecutor() {        return new ThreadPoolExecutor(5, 10, 30, TimeUnit.SECONDS,                new LinkedBlockingQueue<>(1000), new ThreadFactoryBuilder().setNameFormat("test-%s").build()                , new ThreadPoolExecutor.CallerRunsPolicy());    }    private static void exeTask(String name) {        String printStr = "[thread-name:" + Thread.currentThread().getName() + ",执行方式:" + name + "]";        if ("execute-exception".equals(name)) {            throw new RuntimeException(printStr + ", 我抛异常了");        } else {            System.out.println(printStr);        }    }}

执行结果如下:7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

结论:7PQ28资讯网——每日最新资讯28at.com

execute 提交到线程池的方式,如果执行中抛出异常,并且没有在执行逻辑中catch,那么会抛出异常,并且移除抛出异常的线程,创建新的线程放入到线程池中。7PQ28资讯网——每日最新资讯28at.com

验证submit提交线程池中

测试代码:7PQ28资讯网——每日最新资讯28at.com

public class ThreadPoolExecutorDeadTest {    public static void main(String[] args) throws InterruptedException {        ExecutorService executorService = buildThreadPoolExecutor();        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute-exception"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        Thread.sleep(5000);        System.out.println("再次执行任务=======================");        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));    }    public static ExecutorService buildThreadPoolExecutor() {        return new ThreadPoolExecutor(5, 10, 30, TimeUnit.SECONDS,                new LinkedBlockingQueue<>(1000), new ThreadFactoryBuilder().setNameFormat("test-%s").build()                , new ThreadPoolExecutor.CallerRunsPolicy());    }    private static void exeTask(String name) {        String printStr = "[thread-name:" + Thread.currentThread().getName() + ",执行方式:" + name + "]";        if ("execute-exception".equals(name)) {            throw new RuntimeException(printStr + ", 我抛异常了");        } else {            System.out.println(printStr);        }    }}

执行结果如下:7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

结论:7PQ28资讯网——每日最新资讯28at.com

submit 提交到线程池的方式,如果执行中抛出异常,并且没有catch,不会抛出异常,不会创建新的线程。7PQ28资讯网——每日最新资讯28at.com

源码解析

1.java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable);7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

2. 查看execute方法的执行逻辑;7PQ28资讯网——每日最新资讯28at.com

7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

3. java.util.concurrent.ThreadPoolExecutor#processWorkerExit;7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

可以发现,如果抛出异常,会移除抛出异常的线程,创建新的线程。7PQ28资讯网——每日最新资讯28at.com

4. 为什么submit方法,没有创建新的线程,而是继续复用原线程;7PQ28资讯网——每日最新资讯28at.com

还记得,我们在3.1的时候,发现submit也是调用了execute方法,但是在调用之前,包装了一层 RunnableFuture,那一定是在RunnableFuture的实现 FutureTask中有特殊处理了,我们查看源码可以发现。7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

图片图片7PQ28资讯网——每日最新资讯28at.com

但是,我们通过java.util.concurrent.FutureTask#get()就可以获取对应的异常信息。7PQ28资讯网——每日最新资讯28at.com

7PQ28资讯网——每日最新资讯28at.com

总结

当一个线程池里面的线程异常后:7PQ28资讯网——每日最新资讯28at.com

  • 当执行方式是execute时,可以看到堆栈异常的输出,线程池会把这个线程移除掉,并创建一个新的线程放到线程池中。
  • 当执行方式是submit时,堆栈异常没有输出。但是调用Future.get()方法时,可以捕获到异常,不会把这个线程移除掉,也不会创建新的线程放入到线程池中。

以上俩种执行方式,都不会影响线程池里面其他线程的正常执行。7PQ28资讯网——每日最新资讯28at.com

本文链接://www.dmpip.com//www.dmpip.com/showinfo-26-93697-0.htmlJava线程池中线程异常后:是销毁还是复用

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 大厂面试必备:如何轻松实现分布式Session管理?

下一篇: Go必知必会:数组和切片详解

标签:
  • 热门焦点
Top
Baidu
map