上一篇
Java中创建线程池的几种方式及其优缺点是什么？
在Java中，创建线程池是一种高效管理线程的方式，它可以减少创建和销毁线程的开销，提高应用程序的性能,下面将详细介绍如何在Java中创建线程池。
创建线程池的步骤
- 选择线程池类型：Java提供了多种线程池实现，如Executors工厂类中的几种预定义线程池。
- 使用Executors工厂类：Executors类提供了一系列工厂方法来创建不同类型的线程池。
- 自定义线程池：如果预定义的线程池类型不满足需求,可以自定义线程池。
选择线程池类型
| 线程池类型 | 描述 |
|---|---|
| Executors.newCachedThreadPool() | 创建一个可以缓存线程的线程池，当线程空闲时，会缓存一段时间。 |
| Executors.newFixedThreadPool(int nThreads) | 创建一个固定大小的线程池，线程数由nThreads参数指定。 |
| Executors.newSingleThreadExecutor() | 创建一个单线程的线程池，所有任务将顺序执行。 |
| Executors.newScheduledThreadPool(int corePoolSize) | 创建一个可以延迟或定时执行任务的线程池。 |
使用Executors工厂类
以下是一个使用Executors工厂类创建线程池的示例：
这里创建了一个固定大小的线程池,包含5个线程。
自定义线程池
如果需要更灵活的线程池，可以自定义线程池，以下是一个使用ThreadPoolExecutor类创建线程池的示例：
int corePoolSize = 5; // 核心线程数 int maximumPoolSize = 10; // 最大线程数 long keepAliveTime = 60L; // 线程空闲时间 TimeUnit unit = TimeUnit.SECONDS; // 时间单位 BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(); // 工作队列 ThreadPoolExecutor executor = new ThreadPoolExecutor( corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue );
这里创建了一个自定义的线程池，其中包含5个核心线程，最大线程数为10,线程空闲时间为60秒。
示例代码
以下是一个简单的示例,演示如何使用线程池执行任务：
public class ThreadPoolExample { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(5); for (int i = 0; i < 10; i++) { int taskId = i; executor.submit(() > { System.out.println("Executing task " + taskId + " on thread " + Thread.currentThread().getName()); }); } executor.shutdown(); } }
FAQs
Q1：为什么使用线程池？
A1： 使用线程池可以减少创建和销毁线程的开销，提高应用程序的性能，线程池还可以控制并发线程的数量,避免过多线程导致系统资源耗尽。
Q2：如何获取线程池中正在执行的任务数量？
A2： 可以使用ThreadPoolExecutor类的getActiveCount()方法获取当前正在执行的任务数量。
int activeCount = ((ThreadPoolExecutor) executor).getActiveCount(); System.out.println("Active tasks: " + activeCount);
