使用 threadpoolexecutor 显式创建有界线程池可限制最大并发线程数，关键在于构造时明确设置 maximumpoolsize 参数，它决定线程池允许并发执行任务的最大线程数。
Java 限制同时运行的线程最大数量，核心方法是使用 ThreadPoolExecutor 显式创建有界线程池，而不是依赖 Executors 工具类的默认封装（如 newFixedThreadPool 或 newCachedThreadPool）。
明确设置 maximumPoolSize 参数
这是最直接的控制手段。在 ThreadPoolExecutor 构造中，maximumPoolSize 决定了线程池允许并发执行任务的最大线程数：
- 当提交任务时，若当前运行线程数 corePoolSize，会新建核心线程执行；
- 若线程数已达
corePoolSize但队列未满，任务入队等待； - 若队列已满且当前线程数 maximumPoolSize，才扩容新建非核心线程；
- 一旦线程数达到
maximumPoolSize且队列也满，后续任务触发拒绝策略。
例如：最多只允许 6 个线程并发处理导入任务：
new ThreadPoolExecutor(
2, // corePoolSize：常驻2个线程
6, // maximumPoolSize：绝不超6个线程同时运行
60L, // keepAliveTime：空闲线程存活时间
TimeUnit.SECONDS,
new LinkedBlockingQueue(200), // 有界队列，容量200
new ThreadFactoryBuilder().setNameFormat("import-worker-%d").build(),
new ThreadPoolExecutor.AbortPolicy() // 拒绝时抛异常，便于监控告警
);
必须搭配有界队列使用
无界队列（如 LinkedBlockingQueue 无参构造）会让 maximumPoolSize 失效——因为任务永远能进队，线程数永远不会超过 corePoolSize，起不到“限制并发”的作用。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 推荐用
LinkedBlockingQueue(int capacity)或ArrayBlockingQueue，显式设容量； - 队列容量需结合业务预期峰值、内存承受力和响应容忍度来定（比如导入场景设 100～500 较常见）；
- 有界队列 + 合理的
maximumPoolSize，才能真正把并发压在可控范围内。
避免 Executors 工具类的隐藏风险
Executors.newFixedThreadPool(n) 看似设了固定线程数，但它底层用的是无界队列，意味着：
- 所有任务都会进队，永不触发扩容或拒绝；
- 大量积压任务会导致队列无限增长，最终 OOM；
- 无法感知任务积压，缺乏背压机制和告警入口。
所以生产环境应禁用 Executors 的快捷方法，坚持手动构建 ThreadPoolExecutor，把每个参数的意义都掌控住。
配合拒绝策略做主动防御
当线程池已满（线程数 = maximumPoolSize 且队列已满），必须决定如何处理新任务：
-
AbortPolicy：直接抛RejectedExecutionException，适合需要强管控、快速失败的场景； -
CallerRunsPolicy：由提交任务的线程自己执行，可自然降级、减缓提交速度； - 自定义策略：记录日志、发告警、写入死信队列等。
拒绝不是故障，而是限流信号。没有拒绝策略，就等于没有真正的上限。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
