【Java并发进阶】多线程案例核心解析（单例模式、阻塞队列、定时器、线程池...）

在实际开发中多线程不仅仅是“会创建线程”那么简单。如何安全地共享数据、如何协调多个线程之间的协作、如何提升系统性能才是工程中的重点。本文结合经典案例深入理解单例模式、生产者-消费者模型、阻塞队列、定时器、线程池等核心多线程应用场景。一、设计模式设计模式是 Java 开发中针对常见设计问题的可复用、经过验证的解决方案模板。1.单例模式一句话概括单例模式保证一个类在程序中只有一个实例对象并提供一个全局访问点分为懒汉和饿汉两个模式。作用1.控制资源访问避免浪费如如打印机驱动、日志文件写入器等多实例可能造成文件锁冲突或设备状态不一致。2.维护全局状态的一致性如应用的配置信息如数据库URL、环境变量应该只加载一次所有模块都从同一个对象获取保证数据统一。3.避免逻辑冲突和错误如计数器、ID生成器如果存在多个实例各自维护计数会导致ID重复或计数不准确。4.简化设计提供全局访问点消除了需要将对象实例层层传递的麻烦任何地方都可以通过getInstance()直接获取降低了耦合度也让系统的结构更清晰。常见场景DataSource、Runtime、日志管理器等。①饿汉模式提前加载。类加载时即完成实例创建天然线程安全因为JVM 通过内部锁机制确保该类只被加载一次且静态变量instance只初始化一次public class SingletonHungry { //构造方法私有化保证外部不能调用构造方法初始化new对象(实例) private SingletonHungry() {} //静态成员初始化是在加载类时这里会自动初始化对象instance private static final SingletonHungry instance new SingletonHungry(); //直接调用SingletonHungry.getInstance()获取上面构建好的instance public static SingletonHungry getInstance() { return instance; } }②懒汉模式--多线程版用时加载。使用的时候才创建实例需要处理线程安全问题。public class SingletonLazy { //⭐volatile防止指令重排序 private static volatile SingletonLazy instance; //调用getInstance()时候才实例化 private SingletonLazy() {} public static SingletonLazy getInstance() { //⭐第一次检查若实例存在不为null则直接返回不需要加锁提升性能 if (instance null) { synchronized (SingletonLazy.class) { //class表示锁的是类对象 //⭐第二次检查避免重复实例化new的开销很大 if (instance null) { instance new SingletonLazy(); } } } return instance; } }⭐volatilevolatile 修饰instance具体到instance new SingletonLazy()这一行这个过程涉及1分配内存、2初始化对象、3赋值引用这三个步骤可能被jvm优化成1-3-2这时return instance可能拿到的是只经过13没有经过2初始化对象的实例。⭐第一次判空判断是否要加锁若instance null两个线程去同时访问就不需要进行锁的竞争。⭐第二次判空保证线程安全避免重复实例化。因为如果没有第二个ift1线程首先在第一个if判断为空然后紧接着t2线程也去在第一个if发现也为空就会创建两个实例。2.生产者-消费者模型一句话概括生产者-消费者模型是一种通过共享缓冲区解耦生产者和消费者并协调数据生产与处理速率差异的并发协作模式。构成生产者负责生成数据并将数据放入共享缓冲区。消费者负责从共享缓冲区取出数据并进行处理。共享缓冲区通常为阻塞队列用于存放生产者生成的数据解耦生产者和消费者同时解决速率不匹配问题。---除此之外通常还需要同步机制如锁、信号量来保证线程安全避免数据竞争作用解耦生产者和消费者不直接依赖。削峰填谷缓冲队列可以平衡生产者和消费者处理数据的速度差异。缺点比较复杂性能较低引入了锁竞争常见场景线程池任务队列生产者主线程或任意线程提交 Runnable / Callable 任务缓冲区线程池内部的任务阻塞队列消费者线程池中的工作线程执行任务订单/支付异步处理生产者用户下单/支付请求触发消息缓冲区消息队列消费者库存扣减、积分发放、通知等后台任务保证核心链路快速响应//⭐基于阻塞队列的实现 public class ProducerConsumer { private static final BlockingQueueInteger queue new LinkedBlockingQueue(5);//容量为5 public static void main(String[] args) { Thread producer new Thread(() - { try { // 生产者线程生成0-9共10个整数放入队列 for (int i 0; i 10; i) { queue.put(i); //当队列满时放不进去put() 会阻塞 System.out.println(生产 i); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); //重新将中断标志设为 true } }); Thread consumer new Thread(() - { try { // 消费者线程从队列中取出10个整数并消费 for (int i 0; i 10; i) { Integer val queue.take(); //当队列空时取不出来take() 会阻塞 System.out.println(消费 val); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }); // 启动生产者和消费者线程 producer.start(); consumer.start(); } }⭐阻塞队列:BlockingQueue位于java.util.concurrent包中。它是 Java 并发工具包JUC提供的阻塞队列接口用于简化多线程间的数据共享与同步。BlockingQueue也有offerpollpeek等方法但是这些方法不带有阻塞特性·插入元素add(e)offer(e)offer(e, time, unit)常用--put(e)队列满时阻塞直到有空间可用。·移除元素remove()poll()poll(time, unit)常用--take()队列空时阻塞直到有元素可取。·检查队首不删除element()peek()队列空时返回 null。常用实现类类特点ArrayBlockingQueue-基于数组内部使用一个ReentrantLock可重入锁生产消费共用公平性可配置同一时刻只有一个线程能访问队列初始化时必须指定容量LinkedBlockingQueue-基于链表默认容量为Integer.MAX_VALUE使用两个锁putLock和takeLock生产者之间互斥消费者之间互斥但生产者和消费者可以同时操作PriorityBlockingQueue-基于二叉堆的优先级阻塞队列无界优先级阻塞队列需实现Comparable接口重写compareTo方法。不支持take()的公平等待SynchronousQueue-容量为0容量为0的阻塞队列插入put操作必须等待另一个线程的移除take操作反之亦然。适用于生产者和消费者一一对应的场景二、定时器一句话概括定时器是软件开发中的⼀个重要组件类似于⼀个 闹钟作用是在指定的时间点或延迟后执行任务并可以按固定周期重复执行。Timer类位于java.util.Timer核心方法为schedule相对轻量但单线程任务耗时可能影响后续调度ScheduledExecutorService基于线程池更灵活可靠构成任务队列每个元素是一个Task任务Task带有时间属性通常使用优先级队列按下次执行时间排序确保最早到期的任务排在队首。---不要使⽤ PriorityBlockingQueue, 容易死锁调度线程一个独立的worker线程不断检查任务队列计算当前时间与最近任务执行时间的差值通过 wait / sleep 或条件等待实现精确调度。时间控制机制依赖系统时钟获取当前时间并与任务的下次执行时间进行比较决定是否立即执行或继续等待。任务执行器当任务到达触发时间时由调度线程如 java.util.Timer或线程池如 ScheduledExecutorService来执行任务。若使用单线程调度器长时间运行的任务会阻塞后续任务若使用线程池则支持并发执行。任务管理接口提供添加、取消任务的方法如 schedule、cancel允许在运行时动态调整任务计划。常见场景延迟执行例如订单支付超时关闭、延迟发送通知。周期性任务如定时备份数据、心跳检测、日志清理、定时拉取配置。调度任务在特定时间如每天凌晨执行批处理或报表生成。超时控制设置操作的最大等待时间超时后执行回退或重试逻辑。//标准库定时器Timer Timer timer new Timer(); timer.schedule(new TimerTask() { //⭐核心方法 Override public void run() { System.out.println(任务执行); } }, 3000); // 3秒后执行⭐-----schedule 包含两个参数 第⼀个参数指定即将要执⾏的任务代码, 第⼆个参数指定多⻓时间之后执⾏ (单位为毫秒)----TimerTask是抽象类实现了 Runnable 接口因此该实例本质上是一个可执行的任务----new TimerTask() { ... }创建了一个匿名内部类的实例这个匿名类是TimerTask的子类并重写了其中的 run() 方法。因为TimerTask是抽象类抽象类不可被实例化但是其子类可以。//手写简易定时器:核心--优先级队列 独立扫描线程 public class MyTimer { //内部任务类实现了 Comparable 接口按执行时间排序 private static class Task implements ComparableTask { Runnable command; // 要执行的任务逻辑 long time; // time毫秒后执行 public Task(Runnable command, long delay) { this.command command; // 计算任务的绝对执行时间 当前时间 延迟毫秒数 this.time System.currentTimeMillis() delay; } // 按执行时间升序排序时间小的优先级高队首是最早要执行的任务 Override public int compareTo(Task o) { return Long.compare(this.time, o.time); } } // ⭐优先级阻塞队列线程安全且按任务执行时间自动排序 private PriorityBlockingQueueTask queue new PriorityBlockingQueue(); public MyTimer() { //启动一个工作线程不断从队列中获取任务并执行 Thread worker new Thread(() - { while (true) { //一个线程循环处理任务 try { // ⭐阻塞获取队首任务最早要执行的任务 Task task queue.take(); // long now System.currentTimeMillis(); // ⭐如果任务还没到执行时间就让线程睡眠等待定时阻塞 if (task.time now) { Thread.sleep(task.time - now); } task.command.run(); } catch (InterruptedException e) { break; // 线程被中断时退出循环简单处理 } } }); worker.start(); // 启动工作线程 } public void schedule(Runnable command, long delay) { // 创建任务对象并放入队列工作线程会适时处理 queue.put(new Task(command, delay)); } }⭐PriorityBlockingQueue容易死锁·比较器本身持有了其他锁lockB在比较器的compare方法中编写了获取另一把锁如一lockB的代码。当线程 A 在执行queue.put时它已经持有了队列的内部锁称为lockQ然后在调用比较器时又尝试获取lockB。·锁lockB与队列操作锁形成了循环等待假设线程 A 和线程 B 同时操作同一个PriorityBlockingQueue但B线程先拿到了lockB具体理解如下线程 A正在执行queue.put→ 已经获取了队列内部锁lockQ→ 调用比较器的compare方法 → 试图获取业务锁lockB但此时lockB被线程 B 持有。线程 B正在执行其他代码持有了lockB并且此时它想执行queue.put或queue.take于是尝试获取队列内部锁lockQ但lockQ被线程 A 持有。这样就形成了 循环等待A 等 B 释放 lockBB 等 A 释放 lockQ⭐阻塞获取队首任务当队列为空时当前线程会进入阻塞状态暂停执行直到有其他线程调用queue.put()放入任务阻塞状态会让出cpu上下文消耗比较大⭐Thread.sleep()是一种阻塞操作线程会进入TIMED_WAITING状态直到休眠时间结束或被中断后重新进入就绪队列等待调度。三、线程池一句话概括线程池是一种通过复用一组预先创建的线程来执行任务的技术旨在降低线程创建销毁开销、提高响应速度并有效控制系统资源。作用减少线程创建和销毁的开销统一管理线程资源提升系统响应速度常见场景Web 服务器如 Tomcat、Jetty 使用线程池处理并发 HTTP 请求避免为每个请求创建新线程。批量数据处理如报表生成、数据导入/出、批量文件处理利用线程池并行处理提高吞吐量。Executors和ExecutorService是 Java 并发包java.util.concurrent中用于线程池的两个核心组件·ExecutorService是一个接口继承自Executor接口·Executors是一个工具类静态工厂类提供了大量静态方法用于快速创建不同类型的ExecutorService实例。Executors本质上是 ThreadPoolExecutor 类的封装。·工厂类是指运用工厂模式创建型设计模式的类其核心职责是封装对象的创建逻辑让调用者无需关心具体构造细节只需通过简单的方法调用即可获取所需对象。·【Executor←ExecutorService←ThreadPoolExecutor】Executor 是最顶层的接口ExecutorService 继承自 ExecutorThreadPoolExecutor 是 ExecutorService 的一个具体实现类//标准库常见线程池---Executors 创建线程池的⼏种⽅式 //创建固定线程数的线程池 ExecutorService fixedPool Executors.newFixedThreadPool(5); //创建线程数⽬动态增⻓的线程池 ExecutorService cachedPool Executors.newCachedThreadPool(); //创建只包含单个线程的线程池 ExecutorService singlePool Executors.newSingleThreadExecutor(); /*设定延迟时间后执⾏命令或者定期执⾏命令. 是进阶版的 Timer. */ ScheduledExecutorService scheduledPool Executors.newScheduledThreadPool(3);//构造方法 public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueRunnable workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) //实例化固定大小线程池模拟 newFixedThreadPool // 核心最大5队列为无界LinkedBlockingQueue ThreadPoolExecutor fixedPool new ThreadPoolExecutor( 5, 5, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue() ); for (int i 0; i 10; i) { fixedPool.execute(() - System.out.println(Thread.currentThread().getName())); } fixedPool.shutdown(); //fixedPool实例可使用的方法 //提交任务 execute(Runnable command) //无返回值执行任务。 submit(CallableT task) //返回 FutureT可获取结果或异常。 submit(Runnable task, T result) //返回带结果的 Future。 //关闭线程池 shutdown() //拒绝新任务等待已提交任务执行完。 shutdownNow() //尝试停止正在执行的任务返回未执行的任务列表。 awaitTermination(long timeout, TimeUnit unit) //阻塞等待线程池完全关闭。ThreadPoolExecutor 核心参数参数说明corePoolSize--核心线程数一直存在线程池中的线程数maximumPoolSize--最大线程数最大线程数核心临时线程keepAliveTime--临时线程允许空闲的时间临时线程空闲keepAliveTime后要被销毁unit--keepAliveTime的时间单位是秒, 分钟, 还是其他值workQueue--任务阻塞队列传递任务的阻塞队列threadFactory--线程工厂通过不同线程⼯⼚创建出的线程相当于对⼀些属性进⾏了不同的初始化设置RejectedExecutionHandler--拒绝策略如果任务量超出线程池负荷了接下来怎么处理拒绝策略有四种AbortPolicy(): 超过负荷, 直接抛出异常CallerRunsPolicy(): 调⽤者负责处理多出来的任务DiscardOldestPolicy(): 丢弃队列中最⽼的任务DiscardPolicy(): 丢弃新来的任务总结保证线程安全的思路无共享资源线程私有数据天然安全只读共享不可变对象如String、Integer并发容器ConcurrentHashMap主动同步原子性synchronized、Lock、AtomicXXX可见性volatile、synchronized顺序性happens-before原则