使用线程池创建线程

### 如何使用线程池创建和管理线程 在 Java 中，`ExecutorService` 是用于管理和调度线程的核心接口之一。通过 `Executors` 工具类可以方便地创建不同类型的线程池。以下是关于如何使用线程池来创建和管理线程的具体方法。 #### 创建不同类型线程池 Java 提供了多种预定义的线程池类型，每种类型适用于不同的场景： - **FixedThreadPool**: 使用固定的线程数量处理任务[^1]。 ```java ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5); ``` - **CachedThreadPool**: 动态调整线程的数量，适合执行大量短时间的任务[^1]。 ```java ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); ``` - **SingleThreadExecutor**: 单一线程依次执行所有任务。 ```java ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); ``` - **ScheduledThreadPool**: 支持定时或周期性执行任务[^1]。 ```java ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(4); ``` #### 提交任务到线程池 可以通过两种方式向线程池提交任务：`execute()` 和 `submit()` 方法。 - 对于无返回值的任务，可使用 `execute(Runnable task)` 方法[^5]。 ```java fixedThreadPool.execute(() -> { System.out.println(Thread.currentThread().getName() + " 执行任务"); }); ``` - 如果需要获取任务的结果，则应使用 `submit(Callable<T> task)` 或 `submit(Runnable task)`[^2]。 ```java Future<Integer> future = fixedThreadPool.submit(() -> { int result = 0; for (int i = 1; i <= 10; i++) { result += i; } return result; }); try { Integer sum = future.get(); // 获取计算结果 System.out.println("总和：" + sum); } catch (Exception e) { e.printStackTrace(); } ``` #### 关闭线程池 为了释放资源，在不再需要线程池时应该调用其关闭方法。 - 调用 `shutdown()` 后，线程池将停止接收新的任务，但仍会继续完成已有的任务。 ```java fixedThreadPool.shutdown(); ``` - 若希望立即中断所有正在运行的任务并清除等待队列中的任务，可以调用 `shutdownNow()`。 ```java List<Runnable> unfinishedTasks = fixedThreadPool.shutdownNow(); ``` #### 查询线程池状态 还可以查询当前线程池的状态以便监控性能或者调试程序。 - 判断线程池是否已经关闭可用 `isShutdown()` 方法。 ```java boolean isShutDown = fixedThreadPool.isShutdown(); ``` - 查看活动线程数目可通过 `getActiveCount()` 方法获得[^5]。 ```java int activeThreads = ((ThreadPoolExecutor)fixedThreadPool).getActiveCount(); ``` ### 注意事项 当自定义线程池时需要注意合理配置核心线程数、最大线程数以及其他参数以优化应用表现[^3]。 ---