首页 > 其他分享 >什么是线程池,线程池的状态,线程池的用法示例

什么是线程池,线程池的状态,线程池的用法示例

时间:2023-10-21 10:46:30浏览次数:30  
标签:示例 创建 用法 任务 线程 关闭 executor 执行

线程池(Thread Pool)是一种用于管理和重复使用线程的并发编程机制。它是一种有效的方式来管理线程的生命周期、控制并发任务的执行,以及减少线程创建和销毁的开销。线程池在多线程应用程序中被广泛使用,因为它可以提高性能、资源利用率和响应速度。

线程池通常包含以下主要组件:

  1. 工作队列(Work Queue):工作队列用于存储待执行的任务,通常是以队列的形式组织。线程池中的线程会从工作队列中取出任务并执行。

  2. 线程池管理器(Thread Pool Manager):线程池管理器负责创建、销毁和管理线程。它会根据需要自动创建新线程或回收空闲线程,并确保线程的数量在一定范围内。

  3. 工作线程(Worker Threads):工作线程是实际执行任务的线程。线程池中包含多个工作线程,它们负责执行从工作队列中取出的任务。

使用线程池的好处包括:

  1. 降低线程创建和销毁的开销:创建和销毁线程是有开销的,线程池可以重复使用线程,减少这些开销。

  2. 控制并发度:线程池可以限制同时执行的线程数量,避免因并发过高导致系统负载过大。

  3. 提高响应速度:线程池能够更快地响应任务请求,因为线程已经准备好,无需等待新线程的创建。

  4. 管理线程生命周期:线程池可以管理线程的生命周期,包括线程的创建、销毁以及异常处理。

  5. 避免资源耗尽:通过限制线程数量,线程池可以防止因过多线程导致系统资源耗尽而崩溃。

在Java中,线程池的实现通常使用java.util.concurrent包中的ExecutorService接口和其实现类,如ThreadPoolExecutor。这些类提供了丰富的方法和参数,允许你自定义线程池的行为,如核心线程数量、最大线程数量、线程空闲时间等。

线程池通常具有以下几种状态:

  1. 运行(Running):线程池创建后,如果有任务提交,且有可用的线程来执行任务,线程池处于运行状态。

  2. 关闭(Shutdown):在调用了线程池的 shutdown() 方法后,线程池会进入关闭状态。在此状态下,线程池不会接受新的任务,但会继续执行已提交的任务。即使处于关闭状态,线程池也不会立即终止,直到所有任务都执行完成后才会停止。

  3. 立即关闭(ShutdownNow):调用了线程池的 shutdownNow() 方法后,线程池会尝试立即停止所有正在执行的任务并中断正在执行的线程,进入立即关闭状态。在此状态下,线程池不会接受新的任务,并尝试中断正在执行的任务。

  4. 终止(Terminated):当线程池完全终止(所有任务都已完成,并且所有线程都已关闭)时,线程池进入终止状态。在终止状态下,线程池不再接受任何任务,也不会再处理任何任务。

使用线程池通常涉及以下步骤:

  1. 创建线程池:首先,你需要创建一个线程池对象。在Java中,你可以使用java.util.concurrent包中的 ExecutorService 接口及其实现类来创建线程池。常见的线程池实现类包括 ThreadPoolExecutorExecutors 工厂类。

    // 使用Executors工厂类创建线程池,但不推荐在生产环境中使用
    ExecutorService executor = Executors.newFixedThreadPool(4); // 创建一个固定大小的线程池,包含4个线程

    在生产环境中,更推荐使用 ThreadPoolExecutor 来自定义线程池的参数,以满足具体需求。

  2. 提交任务:一旦线程池创建好,你可以将任务提交给线程池来执行。任务通常以 RunnableCallable 对象的形式提交。

    executor.submit(new Runnable() {
        @Override
        public void run() {
            // 任务的具体逻辑
        }
    });

    或使用lambda表达式:

    executor.submit(() -> {
        // 任务的具体逻辑
    });

    你还可以使用 invokeAllinvokeAny 方法提交一批任务。

  3. 关闭线程池:在不再需要线程池时,应该关闭它以释放资源。关闭线程池时,确保不再提交新任务。

    executor.shutdown(); // 允许线程池中已提交的任务执行完毕
    // 或者使用 executor.shutdownNow(); 来立即关闭线程池,尝试中断正在执行的任务

    如果你使用了 shutdown(),线程池将等待已提交的任务执行完成,然后关闭。如果你使用了 shutdownNow(),线程池将尝试中断正在执行的任务并立即关闭。

  4. 异常处理:要确保适当地处理任务执行中可能抛出的异常。通常,线程池会捕获并记录任务中的异常,但你可以通过自定义异常处理器来进行更具体的处理。

    executor.setRejectedExecutionHandler(new MyRejectedExecutionHandler()); // 设置自定义的拒绝策略

    MyRejectedExecutionHandler 中,你可以定义拒绝任务的处理逻辑,例如记录日志或采取其他措施。

下面是一个完整的示例:

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(4);

        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            executor.submit(() -> {
                System.out.println("Task " + taskNumber + " executed by thread: " + Thread.currentThread().getName());
            });
        }

        executor.shutdown(); // 关闭线程池
    }
}

这个示例创建了一个固定大小为4的线程池,然后提交了10个任务。每个任务都会被线程池中的一个线程执行。一旦所有任务执行完毕,线程池被关闭。

 

标签:示例,创建,用法,任务,线程,关闭,executor,执行
From: https://www.cnblogs.com/gentle-man/p/17778584.html

相关文章

  • SpringBoot中启用虚拟线程
    1.什么是虚拟线程虚拟线程是JDK21版本正式发布的一个新特性。虚拟线程和平台线程主要区别在于,虚拟线程在运行周期内不依赖操作系统线程:它们与硬件脱钩,因此被称为“虚拟”。这种解耦是由JVM提供的抽象层赋予的。虚拟线程的运行成本远低于平台线程。它们消耗的内存要少得多。这就......
  • 第4节、进程、线程、程序关系简介
    进程、线程、程序关系简介1、进程2、线程3、进程和线程的关系4、程序和进程、线程5、类比说明1、进程进程是表示资源分配的基本单位,又是调度运行的基本单位。例如,用户运行自己的程序,系统就创建一个进程,并为它分配资源,包括各种表格、内存空间、磁盘空间、I/O设备等。然后,把该进程......
  • 创建线程的三种方式:继承Thread、Runnable 接口、Callable 接口
    当在Java中创建线程时,有以下3种方法:1.通过实现Runnable接口:这是Java中创建线程的推荐方式,因为它允许你分离线程的任务(run方法)与线程的执行。以下是创建线程的步骤:创建一个实现Runnable接口的类,该接口包含一个run方法,这个方法将定义线程要执行的任务。classMyRunnableimpl......
  • 线程的状态
    在Java中,线程可以处于不同的状态,这些状态反映了线程的当前状态和活动。线程的状态通常由Java虚拟机(JVM)来管理,而开发人员可以使用多线程编程工具来控制线程的状态转换。Java中的线程状态包括以下几种主要状态:NEW(新建):当创建了一个线程对象,但还没有调用其start()方法时,线程处于新......
  • Go笔记(1)-变量的详细用法
    变量(1)变量的定义Go语言是静态类型的语言,所有类型都需要明确的定义。var是声明变量的关键字使用格式:var变量名变量类型变量命名规范:遵循驼峰格式,首个单词小写,每个新单词的首字母大写varnameString="WY"//var创建String类型的变量namename="JB"......
  • 4、多线程
    多线程一、线程的创建1.1线程的创建方式一:继承Thread类Java为开发者提供了一种类叫做Thread,该类的对象用来表示线程。用此方法创建线程并执行的步骤如下:定义一个子类继承Thread类,并重写run方法创建该子类的实例对象调用start方法启动线程(启动线程后,会自动执行run方法中的......
  • makefile中.PHNOY的用法
    makefile中PHONY的重要性     伪目标是这样一个目标:它不代表一个真正的文件名,在执行make时可以指定这个目标来执行所在规则定义的命令,有时也可以将一个伪目标称为标签。伪目标通过  PHONY来指明。   PHONY定义伪目标的命令一定会被执行,下面尝试分析这种优点的......
  • postgresql【JSONB用法】
    //userNametypecode是我拿到数据结构出来的可以写固定值来测试;code字段为上面设置的唯一约束。如果code值没有变就是修改,否则就是新增INSERTINTO表名(username,type,code)VALUES('${userName}','${type}','${code}')ONCONFLICT9.6语法支持(code)DOUPDATE......
  • shell脚本示例
    目录1.编写脚本技巧2.脚本:color3.脚本:for循环嵌套4.脚本:检测网址联通性5.脚本:密钥分发6.生产脚本:TCP连接数监控-统计TCP11种状态连接数7.生产脚本:日志监控-检查日志刷新时间8.生产脚本-mq队列监控9.脚本:处理ftp文件10.脚本:数组案例11.whilereadline判断两个文件夹相......
  • 第二章 第三四节 线程池技术以及使用 上
    线程池技术介绍1.线程池的作用​ 避免重复不断地创建、销毁线程,浪费系统资源​ PS:线程池可以成一个容器​ 多线程业务:发短信或者发送邮件(异步任务);请求第三方接口(异步任务);2.线程池原理​3.线城池的销毁​ shutDown等待正在执行任务执行完毕,才会销毁​ shutDownNow......