Java线程池七大参数详解和配置

用户11397231

发布于 2024-12-10 19:29:41

2.3K0

文章被收录于专栏：算法算法

Java线程池七大参数详解和配置

Java线程池（ThreadPoolExecutor）是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。以下是线程池的七个关键参数的详解和配置方法：

1. corePoolSize（核心池大小）

含义：线程池中始终保持的线程数量，即使它们处于空闲状态。
作用：当线程池中的线程数量少于corePoolSize时，新任务会直接创建新线程来执行，而不会先放入工作队列。
默认值：根据Runtime.getRuntime().availableProcessors()返回的处理器数量。
配置：根据任务的类型（CPU密集型或IO密集型）和服务器的处理器数量来设置。对于CPU密集型任务，corePoolSize可以设置为处理器数量；对于IO密集型任务，可以设置为处理器数量的两倍或更多。

2. maximumPoolSize（最大池大小）

含义：线程池中允许的最大线程数量。
作用：当工作队列满了之后，如果线程数量没有达到maximumPoolSize，线程池会创建新线程来执行任务。
默认值：Integer.MAX_VALUE。
配置：根据任务的类型和服务器的处理器数量来设置，通常不大于corePoolSize + (核心数 * 2)。

3. keepAliveTime（线程空闲时间）

含义：当线程数超过corePoolSize时，多余的空闲线程能够保持多久（单位：时间）。
作用：超过corePoolSize的线程在空闲时间后会被终止，直到线程数量等于corePoolSize。
默认值：60秒。
配置：根据任务的空闲时间来设置，通常与TimeUnit一起使用。

4. unit（时间单位）

含义：keepAliveTime参数的时间单位。
默认值：TimeUnit.SECONDS。
配置：可以是TimeUnit.NANOSECONDS、TimeUnit.MICROSECONDS、TimeUnit.MILLISECONDS等。

5. workQueue（工作队列）

含义：用于存放待执行任务的阻塞队列。
作用：如果线程池中的线程数量已经达到corePoolSize，新任务会被放入工作队列中等待执行。
默认值：根据构造方法不同而不同，常见的有LinkedBlockingQueue、SynchronousQueue和ArrayBlockingQueue。
配置：根据任务的特性和预期的队列容量来选择队列类型。例如，LinkedBlockingQueue适用于大量任务积压的情况，而SynchronousQueue可以用于减少线程创建的延迟。

6. threadFactory（线程工厂）

含义：用于创建新线程的工厂。
作用：可以自定义线程的名称、优先级等属性。
默认值：默认的线程工厂。
配置：可以根据需要自定义线程名称、设置线程优先级等。

7. rejectedExecutionHandler（饱和策略）

含义：当任务太多，无法被线程池及时处理时，采取的策略。
作用：当工作队列满了，并且线程数量达到了maximumPoolSize时，新任务会根据rejectedExecutionHandler指定的策略被处理。
默认值：AbortPolicy。
配置：可以选择CallerRunsPolicy、DiscardPolicy、DiscardOldestPolicy等。

配置示例

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
import java.util.concurrent.ThreadPoolExecutor.AbortPolicy;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.Executors;

public class ThreadPoolConfigExample {
    public static void main(String[] args) {
        // 核心池大小
        int corePoolSize = 10;
        // 最大池大小
        int maximumPoolSize = 50;
        // 线程空闲时间
        long keepAliveTime = 120;
        // 时间单位
        TimeUnit unit = TimeUnit.SECONDS;
        // 工作队列
        ArrayBlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
        // 线程工厂
        ThreadFactory threadFactory = Executors.defaultThreadFactory();
        // 饱和策略
        RejectedExecutionHandler rejectedExecutionHandler = new AbortPolicy();

        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                corePoolSize,
                maximumPoolSize,
                keepAliveTime,
                unit,
                workQueue,
                threadFactory,
                rejectedExecutionHandler
        );

        // 示例：提交任务到线程池
        threadPoolExecutor.execute(() -> {
            System.out.println("Task is running");
        });

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

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2024-12-10，如有侵权请联系 cloudcommunity@tencent.com 删除

队列