java 创建线程池

原创admin 分类：热门问答 2024-05-07 17:50:24 0

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

线程池与手动创建线程相比，有以下几个显著的优点：

线程复用：线程池中的线程可以在完成任务后被再次利用，避免了频繁创建和销毁线程带来的资源消耗。
控制并发数：线程池可以控制最大的线程数量，避免因为线程数量过多导致系统过载。
线程管理：线程池提供了对线程的统一管理，可以方便地对线程进行监控和操作。

线程池的核心类与方法

在Java中，线程池的实现主要依赖于java.util.concurrent包中的ThreadPoolExecutor类和ScheduledThreadPoolExecutor类。此外，Executors类提供了一些工厂方法来创建预定义配置的线程池。

ThreadPoolExecutor：是最核心的线程池类，提供了丰富的构造参数来定制线程池的具体行为。
ScheduledThreadPoolExecutor：继承自ThreadPoolExecutor，用于延迟执行或定期执行任务。
Executors：提供了一些工厂方法来创建固定大小的线程池、单线程的线程池、可缓存的线程池等。

使用场景

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

网络请求处理
图像或数据处理
定时任务执行

线程池的创建与对比

以下是两种常见的线程池创建方式的对比：

固定大小的线程池

int poolSize = 10;
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(poolSize);

固定大小的线程池拥有固定数量的线程，适用于负载较重且需要严格控制线程数量的场景。

可缓存的线程池

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

可缓存的线程池会根据需要创建新线程，适用于短生命周期的异步任务。

代码案例

以下是两种线程池创建方式的代码案例：

固定大小的线程池案例

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

public class FixedThreadPoolExample {
    public static void main(String[] args) {
        int poolSize = 5;
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(poolSize);
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            fixedThreadPool.execute(() -> {
                System.out.println("Task " + finalI + " is running on thread: " + Thread.currentThread().getName());
            });
        }
        fixedThreadPool.shutdown();
    }
}

可缓存的线程池案例

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

public class CachedThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            cachedThreadPool.execute(() -> {
                System.out.println("Task " + finalI + " is running on thread: " + Thread.currentThread().getName());
            });
        }
        cachedThreadPool.shutdown();
    }
}

相关知识点补充

以下是线程池中一些重要参数的说明表格：

参数	说明
corePoolSize	线程池保留的最小线程数，即使它们处于空闲状态。
maximumPoolSize	线程池中允许的最大线程数。
keepAliveTime	当线程池中正在运行的线程数量超过了`corePoolSize`时，多余的空闲线程能等待新任务的最长时间。
TimeUnit	`keepAliveTime`参数的时间单位。
workQueue	用于存放待执行任务的阻塞队列。
threadFactory	用于创建新线程的工厂。
handler	拒绝策略，当任务太多，无法被线程池及时处理时采取的策略。