java线程池使用demo

原创admin 分类：热门问答 2024-05-11 04:25:14 0

java线程池使用demo
在Java中，线程池是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。通过重用已经创建的线程来执行新的任务，线程池提高了程序的响应速度，并且提供了更好的系统资源管理。

定义与目的

线程池的核心定义是：一个管理线程的池子，用于提高程序的效率。它的目的在于：

减少资源消耗：通过重用已经创建的线程，避免了频繁创建和销毁线程的资源消耗。
提高响应速度：当任务到达时，线程池可以立即使用空闲的线程来执行任务，而不需要等待新线程的创建。
控制线程数量：可以控制最大的线程数量，避免因为线程数量过多而导致的系统资源耗尽。

线程池的核心类与方法

线程池主要由java.util.concurrent包中的ThreadPoolExecutor和ScheduledThreadPoolExecutor类实现。ThreadPoolExecutor是线程池的主要实现类，而ScheduledThreadPoolExecutor则用于延迟执行或定期执行任务。

ThreadPoolExecutor：提供了线程池的四个基本属性：
- corePoolSize：线程池保留的最小线程数，即使它们处于空闲状态。
- maximumPoolSize：线程池中允许的最大线程数。
- keepAliveTime：当线程池中正在运行的线程数量超过了corePoolSize时，多余的空闲线程能等待新任务的最长时间。
- workQueue：一个阻塞队列，用于存放待执行的任务。
ScheduledThreadPoolExecutor：继承自ThreadPoolExecutor，增加了对任务延迟执行或定期执行的支持。

使用场景

线程池适用于执行大量异步任务的场景，例如：

网络服务器处理客户端请求。
实时数据处理系统。
批量图像或视频处理。

代码案例

以下是使用ThreadPoolExecutor的一个简单案例：

import java.util.concurrent.*;

public class ThreadPoolDemo {
    public static void main(String[] args) {
        // 设置线程池参数
        int corePoolSize = 5;
        int maximumPoolSize = 10;
        long keepAliveTime = 1L;
        ThreadFactory threadFactory = Executors.defaultThreadFactory();
        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>();

        // 创建线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                corePoolSize,
                maximumPoolSize,
                keepAliveTime,
                TimeUnit.MINUTES,
                workQueue,
                threadFactory
        );

        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            executor.submit(() -> {
                System.out.println("执行任务: " + finalI + " 由线程 " + Thread.currentThread().getName() + " 处理");
            });
        }

        // 关闭线程池，不再接受新任务
        executor.shutdown();
    }
}

问题	回答
线程池中的线程是守护线程吗？	默认情况下，线程池中的线程是用户线程，不是守护线程。但是可以通过`ThreadFactory`创建守护线程。
如何处理线程池拒绝的任务？	可以设置`RejectedExecutionHandler`来处理拒绝的任务。常见的策略有丢弃任务、抛出异常等。
线程池的线程数量应该如何设置？	线程数量应该根据任务特性和系统资源进行调整。一般建议设置为CPU核心数的2倍。
线程池中的线程是否可以执行定时任务？	`ScheduledThreadPoolExecutor`可以执行定时任务，而`ThreadPoolExecutor`不行。

对比表格

属性/方法	`ThreadPoolExecutor`	`ScheduledThreadPoolExecutor`
延迟或定时任务	不支持	支持
核心线程数	可设置	可设置
最大线程数	可设置	可设置
线程存活时间	可设置	可设置
工作队列	可设置	可设置
默认实现	`Executor`接口的直接实现	`ThreadPoolExecutor`的扩展
适用场景	短生命周期的异步任务	需要定时或延迟执行的任务