当前位置：首页 > news >正文

线程池参数怎么配才不翻车

news 2026/6/10 12:35:57

这篇不空谈理论，直接给一套业务里能用的参数配置和代码模板。

先给结论

线程池配置最容易出问题的地方就三个：

队列无界，任务堆到 OOM
最大线程数乱设，把机器打满
拒绝策略没兜底，线上直接丢任务

下面我们用一套可落地模板解决它。

一、先准备一个“可观测”的线程池工厂

importjava.util.concurrent.*;importjava.util.concurrent.atomic.AtomicInteger;publicfinalclassBizThreadPoolFactory{privateBizThreadPoolFactory(){}publicstaticThreadPoolExecutornewIoPool(Stringname,intcore,intmax,intqueueSize){// 线程命名，线上排查时能直接看出业务来源ThreadFactorythreadFactory=newThreadFactory(){privatefinalAtomicIntegeridx=newAtomicInteger(1);@OverridepublicThreadnewThread(Runnabler){Threadt=newThread(r,name+"-"+idx.getAndIncrement());t.setDaemon(false);returnt;}};// 有界队列：防止任务无限堆积BlockingQueue<Runnable>queue=newArrayBlockingQueue<>(queueSize);// CallerRunsPolicy：降级回调用线程执行，给上游施压，而不是直接丢任务RejectedExecutionHandlerrejectHandler=newThreadPoolExecutor.CallerRunsPolicy();returnnewThreadPoolExecutor(core,max,60L,TimeUnit.SECONDS,queue,threadFactory,rejectHandler);}}

二、参数怎么给

1) CPU 密集型任务

intcpu=Runtime.getRuntime().availableProcessors();ThreadPoolExecutorpool=BizThreadPoolFactory.newIoPool("cpu-task",cpu,cpu+1,200);

适合：压缩、加密、规则计算。

2) IO 密集型任务

intcpu=Runtime.getRuntime().availableProcessors();ThreadPoolExecutorpool=BizThreadPoolFactory.newIoPool("io-task",cpu*2,cpu*4,1000);

适合：RPC、数据库、磁盘读写。

三、业务代码里怎么用

importjava.util.concurrent.*;publicclassOrderQueryService{privatefinalThreadPoolExecutorioPool=BizThreadPoolFactory.newIoPool("order-io",16,32,1000);publicStringqueryWithTimeout(StringorderId){Future<String>future=ioPool.submit(()->remoteCall(orderId));try{// 超时必须有，不然线程会一直卡住returnfuture.get(800,TimeUnit.MILLISECONDS);}catch(TimeoutExceptione){future.cancel(true);return"timeout-fallback";}catch(Exceptione){return"error-fallback";}}privateStringremoteCall(StringorderId){// 模拟远程调用return"ok-"+orderId;}}

四、监控必须加

publicfinalclassThreadPoolMetrics{publicstaticStringsnapshot(ThreadPoolExecutorpool){return"poolSize="+pool.getPoolSize()+", active="+pool.getActiveCount()+", queue="+pool.getQueue().size()+", completed="+pool.getCompletedTaskCount()+", taskCount="+pool.getTaskCount();}}

定时打印或上报这几个值，线上问题会好排查很多。

五、优雅关闭

publicstaticvoidshutdownGracefully(ThreadPoolExecutorpool){pool.shutdown();// 拒绝新任务try{if(!pool.awaitTermination(30,TimeUnit.SECONDS)){pool.shutdownNow();// 超时后强制中断}}catch(InterruptedExceptione){pool.shutdownNow();Thread.currentThread().interrupt();}}

六、一个完整配置建议

intcpu=Runtime.getRuntime().availableProcessors();ThreadPoolExecutorbizPool=BizThreadPoolFactory.newIoPool("biz-main",Math.max(8,cpu*2),// coreMath.max(16,cpu*4),// max2000// queueSize);