有几种创建线程池的方式

线程池的出现主要是为了解决频繁创建和销毁线程所带来的性能开销问题。线程池可以复用线程，避免了线程的重复创建和销毁，从而提高了程序的性能。此外，线程池还可以控制线程的数量，避免因为创建线程过多而导致的内存溢出问题，并且提供了任务管理的功能，可以实现任务缓存和任务拒绝的情况。线程池的创建方式有两种：通过ThreadPoolExecutor创建的线程池和通过Executors创建的线程池。其中，通过ThreadPoolExecutor创建的线程池可以自定义线程池的各种参数，而通过Executors创建的线程池则提供了一些常用的线程池类型，如FixedThreadPool、CachedThreadPool等。

### 如何在Java中创建线程池 #### 使用`Executors`工具类创建不同类型的线程池 Java 提供了 `Executors` 类作为便捷的工厂类用于创建多种类型的线程池。下面列举了几种常用的方式： - **Fixed Thread Pool** 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。 ```java ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10); ``` 这段代码展示了如何利用 `Executors.newFixedThreadPool(int nThreads)` 方法来构建具有固定数量工作线程的线程池[^2]。 - **Single Thread Executor** 创建单个工作线程执行器，它会保证所有的任务都在同一个线程内按顺序执行。 ```java ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); ``` 此处使用的是 `Executors.newSingleThreadExecutor()` 来实例化仅含单一后台线程的线程池[^3]。 - **Cached Thread Pool** 创建一个可根据需要调整大小的线程池，适用于大量短期异步任务。 ```java ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); ``` 上述代码片段说明了通过调用 `Executors.newCachedThreadPool()` 可获得能够动态增加新线程的数量以适应负载变化的线程池[^4]。 除了上述简单快捷的方法外，还可以更精细地定制线程池的行为模式，比如设置核心池大小、最大池大小、保持存活时间等参数。这通常涉及到直接使用 `ThreadPoolExecutor` 构造函数来进行初始化[^5]。 ```java import java.util.concurrent.*; public class CustomThreadPoolExample { public static void main(String[] args) { ThreadPoolExecutor executor = new ThreadPoolExecutor( 2, // 核心线程数 4, // 最大线程数 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy() ); for (int i = 0; i < 10; ++i) { Runnable worker = new WorkerThread("" + i); executor.execute(worker); } executor.shutdown(); while (!executor.isTerminated()) {} System.out.println("Finished all threads"); } static class WorkerThread implements Runnable { private String command; public WorkerThread(String s){ this.command=s; } @Override public void run() { System.out.println(Thread.currentThread().getName()+" Start. Command = "+command); processCommand(); System.out.println(Thread.currentThread().getName()+" End."); } protected void processCommand(){ try{ Thread.sleep(500); // Simulate work being done. } catch (InterruptedException e){} } } } ``` 此自定义线程池的例子不仅指定了具体的线程数目范围，还设置了当请求阻塞时所采用的任务拒绝策略——这里选择了让调用者自己运行被拒任务(`CallerRunsPolicy`) 的方式处理超载情况。