“线程池中线程异常后：销毁还是复用？”

news2024/11/13 10:23:05

一、验证execute提交线程池中

测试

结论

二、验证submit提交线程池中

测试

结论

三、源码解析

查看submit方法的执行逻辑

查看execute方法的执行逻辑

为什么submit方法，没有创建新的线程，而是继续复用原线程？

四、总结

需要说明，本文的线程池都是java.util.concurrent.ExecutorService线程池，本文将围绕验证，阅读源码俩方面来解析这个问题。

一、验证execute提交线程池中

测试

我们首先定义了一个 ThreadPoolExecutorDeadTest 类，用来演示 Java 中 ThreadPoolExecutor 的使用，以及在任务执行过程中发生异常时线程池的行为。然后，在代码中，通过创建一个线程池并提交多个任务来模拟线程池的运行情况，其中一个任务故意抛出异常。

测试代码如下：

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);
    }
  }
}

首先，调用 buildThreadPoolExecutor() 方法创建一个线程池并赋值给 executorService。这个线程池具有核心线程数 5，最大线程数 10，空闲线程存活时间 30 秒，任务队列容量为 1000，使用 CallerRunsPolicy 作为拒绝策略。

然后，调用 executorService.execute() 方法多次向线程池提交任务。任务类型为 Runnable，任务的内容是调用 exeTask 方法。

主线程在前五个任务提交后，调用 Thread.sleep(5000) 暂停5秒，以模拟任务执行间隔。在暂停后，向线程池再次提交五个任务，继续执行。

运行结果如下，

可以看到test-2线程不见了，出现了test-3线程。

结论

execute 提交到线程池的方式，如果执行中抛出异常，并且没有在执行逻辑中catch，那么会抛出异常，并且移除抛出异常的线程，创建新的线程放入到线程池中。

二、验证submit提交线程池中

测试

测试代码：

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);
    }
  }
}

运行结果如下，

可以看到test-2线程执行异常了，并没有抛出异常栈而且继续复用了，没有被移除。

结论

submit 提交到线程池的方式，如果执行中抛出异常，并且没有catch，不会抛出异常，不会创建新的线程。

三、源码解析

查看submit方法的执行逻辑

我们从上述测试代码中的executorService.submit(() -> exeTask("execute"));，进入到 java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable)方法，可以看到，submit方法，也是包装了RunnableFuture后调用execute方法。