java threadpoolexecutor使用详解

### Java 中 `ThreadPoolExecutor` 的详细使用方法 #### 创建线程池实例 为了创建一个 `ThreadPoolExecutor` 实例，需要指定核心线程数、最大线程数、线程存活时间以及工作队列等参数。下面是一个具体的例子： ```java import java.util.concurrent.*; public class ThreadPoolExample { public static void main(String[] args) { ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, // 核心线程数 10, // 最大线程数 1L, TimeUnit.MINUTES, // 线程空闲后的生存时间设为1分钟 new LinkedBlockingQueue<Runnable>(), // 使用无界阻塞队列存储等待执行的任务 Executors.defaultThreadFactory() // 默认的线程工厂用于创建新线程 ); // 提交多个任务给线程池处理 for (int i = 0; i < 20; ++i){ final int taskID = i; executor.execute(() -> System.out.println("Task ID:" + taskID)); } // 关闭线程池 executor.shutdown(); } } ``` 这段代码展示了如何配置并启动一个具有固定范围的核心和最大线程数量的线程池[^2]。 #### 执行提交的任务 当向线程池提交任务时，如果当前运行中的线程少于核心线程数目，则会立即创建新的线程来执行这些任务；一旦达到核心线程的数量限制，后续到来的任务会被放入到工作队列中排队等候被执行。只有当所有非守护状态下的线程都在忙碌，并且队列已满的情况下才会考虑增加超过核心大小的工作线程直到不超过设定的最大值为止。 对于上述程序输出的结果来看，可以观察到不同名称的线程被用来完成不同的任务请求[^3]。 #### 控制线程池关闭行为 调用 `shutdown()` 方法之后不会再接受任何新的任务进入该线程池，但是已经存在于内部队列里的待办事项还是会继续得到处理直至结束。另外还有强制性的终止方式如 `shutdownNow()` 可供选择，在这种情况下不仅停止接收新任务还会尝试中断正在执行中的操作。 #### 获取已完成任务的信息 通过实现 Callable 接口代替 Runnable 并利用 Future 对象能够获取异步计算产生的结果或者异常情况报告。 ```java Future<Integer> futureResult = executor.submit(new Callable<Integer>() { @Override public Integer call() throws Exception { return someComputation(); // 返回某个整数值作为函数返回值 } }); try{ Integer result = futureResult.get(); // 阻塞主线程直到获得结果 }catch(Exception e){ // 处理可能出现的各种异常状况 } ``` 以上就是有关 `ThreadPoolExecutor` 类的一些基本概念及其应用实践介绍[^1]。