Java 线程池都有哪些状态?

发布时间:2024年01月05日

Java 线程池都有哪些状态?

在Java中,线程池的状态主要包括RUNNING(运行)、SHUTDOWN(关闭)、STOP(停止)和TIDYING(整理)等。这些状态由ThreadPoolExecutor类中的ctl字段管理,ctl字段的高3位表示线程池的状态,低29位表示线程的数量。以下是线程池的几种状态:

  1. RUNNING(运行):

    • 表示线程池处于正常运行状态。
    • 线程池被创建后一直处于运行状态,当调用shutdown()方法时,会切换到SHUTDOWN状态。
  2. SHUTDOWN(关闭):

    • 表示线程池正在关闭状态。
    • 当调用shutdown()方法后,线程池会拒绝新任务,但会继续处理已经提交的任务。
  3. STOP(停止):

    • 表示线程池停止状态。
    • 当调用shutdownNow()方法后,线程池会拒绝新任务,并尝试停止所有正在执行的任务。
  4. TIDYING(整理):

    • 表示线程池正在整理状态。
    • 在所有任务都已经终止,工作线程数量为零时,线程池会切换到这个状态。
  5. TERMINATED(终止):

    • 表示线程池已经终止状态。
    • 在整理完毕后,线程池会切换到这个状态。

以下是一个简单的示例,演示了如何使用线程池,并获取线程池的状态:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadPoolExample {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        // 获取线程池状态
        System.out.println("线程池状态: " + getThreadPoolStatus(executorService));

        // 提交任务
        executorService.submit(() -> {
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task 1 executed");
        });

        // 提交任务
        executorService.submit(() -> System.out.println("Task 2 executed"));

        // 关闭线程池
        executorService.shutdown();

        // 获取线程池状态
        System.out.println("线程池状态: " + getThreadPoolStatus(executorService));
    }

    private static String getThreadPoolStatus(ExecutorService executorService) {
        if (executorService instanceof ThreadPoolExecutor) {
            ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executorService;
            int state = threadPoolExecutor.getRunState();
            switch (state) {
                case -1:
                    return "TERMINATED";
                case 0:
                    return "RUNNING";
                case 1:
                    return "SHUTDOWN";
                case 2:
                    return "STOP";
                case 3:
                    return "TIDYING";
                default:
                    return "Unknown State";
            }
        } else {
            return "Not a ThreadPoolExecutor";
        }
    }
}

在这个示例中,创建了一个固定大小的线程池,提交了两个任务后,关闭了线程池,并通过getThreadPoolStatus方法获取线程池的状态。

文章来源:https://blog.csdn.net/sanmansan/article/details/135347318
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。