JAVA多线程并发编程：线程池原理与实战应用

JAVA多线程并发编程线程池原理与实战应用学习目标掌握JAVA线程池的核心原理、核心参数配置方法能够结合实际场景完成线程池的自定义创建与优化解决多线程并发场景中的资源浪费问题。学习重点线程池的工作流程、ThreadPoolExecutor核心参数含义、四种常见线程池的适用场景、线程池实战案例开发。1.1 为什么需要线程池在JAVA多线程编程中直接创建和销毁线程会带来严重的性能问题。每一个线程的创建都需要占用JVM内存和CPU资源。频繁创建线程会导致系统频繁进行资源调度。这种情况会大幅降低程序运行效率。⚠️注意事项单个线程默认占用的栈内存大小为1MB。如果无限制创建线程会直接引发OutOfMemoryError内存溢出异常。✅核心结论线程池的本质是线程复用。它会预先创建一定数量的线程。这些线程可以重复执行多个任务。这种方式减少了线程创建和销毁的开销提高了并发程序的稳定性和效率。1.2 线程池的核心原理与工作流程1.2.1 线程池的核心工作机制线程池的工作流程遵循任务提交-线程分配-任务执行-线程回收的逻辑。具体步骤如下① 任务提交将需要执行的任务Runnable或Callable对象提交到线程池的任务队列中。② 线程判断线程池会判断核心线程数是否已满。如果核心线程有空闲直接分配核心线程执行任务。③ 队列存储核心线程已满时会将任务存入阻塞队列。阻塞队列未满时任务会等待空闲线程。④ ➕线程扩容阻塞队列已满时线程池会判断是否达到最大线程数。未达到则创建非核心线程执行任务。⑤ ❌任务拒绝达到最大线程数时会触发拒绝策略。线程池会按照预设规则处理无法接收的任务。1.2.2 线程池核心参数ThreadPoolExecutorThreadPoolExecutor是JAVA线程池的核心实现类。它的构造方法包含7个核心参数。掌握这些参数的配置规则是线程池优化的关键。publicThreadPoolExecutor(intcorePoolSize,intmaximumPoolSize,longkeepAliveTime,TimeUnitunit,BlockingQueueRunnableworkQueue,ThreadFactorythreadFactory,RejectedExecutionHandlerhandler){// 构造方法逻辑}corePoolSize核心线程数 线程池长期保持的线程数量。核心线程不会因为空闲而被销毁。除非设置了allowCoreThreadTimeOut(true)。maximumPoolSize最大线程数 线程池允许创建的最大线程数量。它包含核心线程和非核心线程。keepAliveTime非核心线程空闲时间 非核心线程空闲超过该时间会被销毁。这个参数可以控制线程池的资源占用。unit时间单位keepAliveTime的时间单位。常用的有TimeUnit.SECONDS、TimeUnit.MILLISECONDS。workQueue任务阻塞队列 用于存储等待执行的任务。常见的实现类有ArrayBlockingQueue、LinkedBlockingQueue、SynchronousQueue。threadFactory线程工厂 用于创建新线程。可以自定义线程名称、优先级等属性。handler拒绝策略 任务队列和最大线程数都满时的处理策略。JDK提供了4种默认拒绝策略。1.3 JDK四种常见线程池的应用场景JDK通过Executors工具类提供了四种预定义线程池。它们适用于不同的业务场景。在实际开发中需要根据需求选择。1.3.1FixedThreadPool固定线程数线程池核心特点核心线程数最大线程数。没有非核心线程。任务队列使用无界队列LinkedBlockingQueue。适用场景适用于任务量稳定、需要控制并发线程数的场景。例如接口限流、定时任务执行。创建方式// 创建固定5个线程的线程池ExecutorServicefixedThreadPoolExecutors.newFixedThreadPool(5);1.3.2CachedThreadPool缓存线程池核心特点核心线程数为0。最大线程数为Integer.MAX_VALUE。任务队列使用SynchronousQueue。适用场景适用于任务量波动大、执行时间短的场景。例如临时的批量数据处理。创建方式ExecutorServicecachedThreadPoolExecutors.newCachedThreadPool();1.3.3SingleThreadExecutor单线程线程池核心特点只有1个核心线程。任务按顺序执行。可以保证任务的执行顺序。适用场景适用于需要任务串行执行的场景。例如日志写入、订单状态更新。创建方式ExecutorServicesingleThreadExecutorExecutors.newSingleThreadExecutor();1.3.4ScheduledThreadPool定时任务线程池核心特点支持延迟执行和周期性执行任务。基于DelayedWorkQueue实现。适用场景适用于定时任务、周期性任务。例如心跳检测、数据同步。创建方式// 创建核心线程数为3的定时线程池ScheduledExecutorServicescheduledThreadPoolExecutors.newScheduledThreadPool(3);⚠️注意事项Executors提供的线程池存在一定局限性。例如FixedThreadPool的无界队列可能导致内存溢出。在生产环境中推荐使用ThreadPoolExecutor自定义线程池。1.4 线程池拒绝策略详解当任务队列已满且线程数达到最大值时线程池会触发拒绝策略。JDK提供了4种默认拒绝策略。开发者也可以自定义拒绝策略。拒绝策略类核心逻辑适用场景AbortPolicy直接抛出RejectedExecutionException异常适用于需要明确感知任务拒绝的场景CallerRunsPolicy由提交任务的线程执行该任务适用于并发量较小的场景DiscardPolicy直接丢弃该任务不做任何处理适用于允许丢失部分任务的场景DiscardOldestPolicy丢弃队列中最旧的任务尝试提交新任务适用于任务时效性较强的场景1.5 实战案例自定义线程池实现订单异步处理在电商系统中订单创建后需要进行库存扣减、短信通知、日志记录等操作。这些操作可以通过线程池异步执行。这种方式可以提高接口响应速度。1.5.1 需求分析订单创建接口需要快速返回结果。库存扣减、短信通知等操作异步执行。控制并发线程数避免因并发过高导致系统资源耗尽。任务执行失败时需要记录日志方便后续排查问题。1.5.2 代码实现步骤1自定义线程工厂设置线程名称importjava.util.concurrent.ThreadFactory;importjava.util.concurrent.atomic.AtomicInteger;publicclassOrderThreadFactoryimplementsThreadFactory{privatefinalAtomicIntegerthreadNumbernewAtomicInteger(1);privatefinalStringnamePrefix;publicOrderThreadFactory(StringnamePrefix){this.namePrefixnamePrefix-thread-;}OverridepublicThreadnewThread(Runnabler){ThreadthreadnewThread(r,namePrefixthreadNumber.getAndIncrement());// 设置线程为非守护线程thread.setDaemon(false);// 设置线程优先级为普通thread.setPriority(Thread.NORM_PRIORITY);returnthread;}}步骤2自定义拒绝策略记录拒绝任务日志importjava.util.concurrent.RejectedExecutionHandler;importjava.util.concurrent.ThreadPoolExecutor;publicclassOrderRejectedPolicyimplementsRejectedExecutionHandler{OverridepublicvoidrejectedExecution(Runnabler,ThreadPoolExecutorexecutor){// 记录拒绝任务日志System.out.println(任务 r.toString() 被拒绝当前线程池状态核心线程数executor.getCorePoolSize()活跃线程数executor.getActiveCount()任务队列大小executor.getQueue().size());// 可以选择抛出异常或其他处理逻辑thrownewRuntimeException(任务 r.toString() 执行失败线程池已满);}}步骤3创建自定义线程池importjava.util.concurrent.ArrayBlockingQueue;importjava.util.concurrent.ThreadPoolExecutor;importjava.util.concurrent.TimeUnit;publicclassOrderThreadPool{// 核心线程数CPU核心数*2privatestaticfinalintCORE_POOL_SIZERuntime.getRuntime().availableProcessors()*2;// 最大线程数CPU核心数*4privatestaticfinalintMAXIMUM_POOL_SIZERuntime.getRuntime().availableProcessors()*4;// 非核心线程空闲时间60秒privatestaticfinallongKEEP_ALIVE_TIME60L;// 任务队列大小100privatestaticfinalintQUEUE_CAPACITY100;privatestaticfinalThreadPoolExecutorexecutor;static{executornewThreadPoolExecutor(CORE_POOL_SIZE,MAXIMUM_POOL_SIZE,KEEP_ALIVE_TIME,TimeUnit.SECONDS,newArrayBlockingQueue(QUEUE_CAPACITY),newOrderThreadFactory(order-process),newOrderRejectedPolicy());// 允许核心线程超时销毁可选executor.allowCoreThreadTimeOut(false);}// 获取线程池实例publicstaticThreadPoolExecutorgetExecutor(){returnexecutor;}// 关闭线程池应用停止时调用publicstaticvoidshutdown(){executor.shutdown();}}步骤4定义异步任务并提交// 库存扣减任务classStockDeductTaskimplementsRunnable{privatefinalStringorderId;privatefinalIntegerproductId;privatefinalIntegernum;publicStockDeductTask(StringorderId,IntegerproductId,Integernum){this.orderIdorderId;this.productIdproductId;this.numnum;}Overridepublicvoidrun(){try{// 模拟库存扣减逻辑System.out.println(订单 orderId 开始扣减商品 productId 库存数量num);Thread.sleep(500);// 模拟业务处理时间System.out.println(订单 orderId 库存扣减完成);}catch(InterruptedExceptione){Thread.currentThread().interrupt();System.out.println(订单 orderId 库存扣减任务被中断);}}}// 短信通知任务classSmsNotifyTaskimplementsRunnable{privatefinalStringorderId;privatefinalStringphone;publicSmsNotifyTask(StringorderId,Stringphone){this.orderIdorderId;this.phonephone;}Overridepublicvoidrun(){try{System.out.println(向手机号 phone 发送订单 orderId 通知短信);Thread.sleep(300);// 模拟短信发送时间System.out.println(订单 orderId 短信通知发送完成);}catch(InterruptedExceptione){Thread.currentThread().interrupt();System.out.println(订单 orderId 短信通知任务被中断);}}}// 测试类publicclassOrderThreadPoolTest{publicstaticvoidmain(String[]args){StringorderIdORDER_20240520_001;Stringphone13800138000;IntegerproductId1001;Integernum2;// 获取自定义线程池ThreadPoolExecutorexecutorOrderThreadPool.getExecutor();// 提交异步任务executor.submit(newStockDeductTask(orderId,productId,num));executor.submit(newSmsNotifyTask(orderId,phone));// 模拟主线程业务逻辑System.out.println(订单 orderId 创建成功异步任务已提交);// 应用停止时关闭线程池// OrderThreadPool.shutdown();}}1.5.3 运行结果订单 ORDER_20240520_001 创建成功异步任务已提交 订单 ORDER_20240520_001 开始扣减商品 1001 库存数量2 向手机号 13800138000 发送订单 ORDER_20240520_001 通知短信 订单 ORDER_20240520_001 短信通知发送完成 订单 ORDER_20240520_001 库存扣减完成✅实战结论通过自定义线程池实现了订单相关任务的异步执行。这种方式既提高了接口响应速度又通过核心参数配置控制了系统资源占用。自定义拒绝策略可以保证任务拒绝时的可观测性。1.6 线程池的监控与优化技巧1.6.1 线程池监控指标在生产环境中需要对线程池的运行状态进行监控。关键监控指标如下getCorePoolSize()获取核心线程数getMaximumPoolSize()获取最大线程数getActiveCount()获取当前活跃线程数getQueue().size()获取任务队列中的任务数getCompletedTaskCount()获取已完成的任务数1.6.2 线程池优化原则核心线程数配置CPU密集型任务设置为CPU核心数1IO密集型任务设置为CPU核心数*2。任务队列选择避免使用无界队列推荐使用有界队列ArrayBlockingQueue并设置合理容量。拒绝策略选择生产环境不推荐使用DiscardPolicy建议使用CallerRunsPolicy或自定义拒绝策略。线程池关闭应用停止时必须调用shutdown()或shutdownNow()关闭线程池释放资源。1.7 本章小结 本章重点讲解了JAVA线程池的核心原理、ThreadPoolExecutor核心参数、四种常见线程池的应用场景。通过订单异步处理的实战案例掌握了自定义线程池的开发方法。✅ 线程池是解决多线程并发问题的核心技术。合理配置线程池参数、选择合适的拒绝策略和任务队列能够有效提升并发程序的性能和稳定性。