Java锁工具实战：pan-common告别手动lock/unlock

Java 锁工具实战LockExecutors 如何用函数式封装告别手动 lock/unlock选题说明并发编程中synchronized虽然简单但不够灵活ReentrantLock灵活但容易忘记unlock导致死锁。LockExecutors用函数式编程思想重新封装了 Java 三种主流锁让临界区代码像 Lambda 一样简洁同时自动管理锁生命周期彻底杜绝锁泄漏。一、为什么需要锁执行器先看一段典型的ReentrantLock使用代码privatefinalReentrantLocklocknewReentrantLock();publicvoidupdateData(){lock.lock();try{// 真正的业务逻辑只有这一行dataService.update();}finally{lock.unlock();}}问题显而易见模板代码太多每个加锁方法都要写lock/try/finally/unlock四行模板容易忘记unlock新人入职第一天就可能写出没有finally的代码异常泄漏风险try块抛出异常后如果忘记finally锁永远不会释放锁对象散落各处多个方法共享同一把锁时锁声明和使用的对应关系不直观读写锁更复杂readLock()和writeLock()分别获取代码量翻倍LockExecutors的设计目标就是你只需要关心临界区代码锁的获取和释放由框架自动管理。环境准备!-- Spring Boot 2.x (javax) --dependencygroupIdcom.gitee.apanlh/groupIdartifactIdpan-common/artifactIdversion2.0.6/version/dependency!-- Spring Boot 3.x (jakarta) --dependencygroupIdcom.gitee.apanlh/groupIdartifactIdpan-common/artifactIdversion3.0.6/version/dependency二、三种锁执行器对比执行器底层锁可重入读写分离适用场景ReentrantLockExecutorReentrantLock是否通用互斥场景ReadWriteLockExecutorReentrantReadWriteLock是是读多写少场景缓存StampedLockExecutorStampedLock否是高性能读写场景选型建议大多数场景用ReentrantLockExecutor简单可靠读操作远多于写操作用ReadWriteLockExecutor读锁共享不互斥追求极致性能且能保证不重入时用StampedLockExecutor三、ReentrantLockExecutor最通用的选择3.1 无返回值场景// 创建锁执行器ReentrantLockExecutorlockExecutorLockExecutors.newReentrantLock();// 加锁执行自动 lock/unlocklockExecutor.lock(()-{// 需要同步的代码无需手动 try/finallydataService.update();System.out.println(线程安全操作完成);});对比手写ReentrantLock代码量减少了 60%// 手写方式4 行模板代码lock.lock();try{dataService.update();}finally{lock.unlock();}// LockExecutors 方式1 行核心代码lockExecutor.lock(()-dataService.update());3.2 带返回值场景使用Supplier重载临界区代码可以返回值// 带返回值的锁执行StringresultlockExecutor.lock(()-{returndataService.query();});// 计数器场景intcountlockExecutor.lock(()-{returncounter.incrementAndGet();});3.3 异常自动处理临界区抛出异常时锁仍然正确释放lockExecutor.lock(()-{// 即使这里抛出异常lock 也会在 finally 中释放riskyOperation();});// 后续代码正常执行不会死锁四、ReadWriteLockExecutor读多写少场景当读操作远多于写操作时如缓存读写锁可以显著提升并发性能读锁共享多个线程可以同时读写锁互斥同一时刻只有一个线程能写。4.1 读写分离ReadWriteLockExecutorrwLockLockExecutors.newReadWriteLock();// 读操作 —— 多线程可同时执行ObjectvaluerwLock.readLock(()-{returncache.get(key);});// 写操作 —— 互斥执行rwLock.writeLock(()-{cache.put(key,newValue);});4.2 实战线程安全的本地缓存publicclassSafeCacheK,V{privatefinalMapK,VcachenewHashMap();privatefinalReadWriteLockExecutorrwLockLockExecutors.newReadWriteLock();publicVget(Kkey){returnrwLock.readLock(()-cache.get(key));}publicvoidput(Kkey,Vvalue){rwLock.writeLock(()-cache.put(key,value));}publicvoidremove(Kkey){rwLock.writeLock(()-cache.remove(key));}publicvoidclear(){rwLock.writeLock(cache::clear);}publicintsize(){returnrwLock.readLock(cache::size);}}五、StampedLockExecutor高性能读写锁StampedLock是 JDK 8 引入的高性能锁比ReentrantReadWriteLock更快但不可重入。5.1 基本用法StampedLockExecutorstampedLockLockExecutors.newStampedLock();// 读锁ObjectvaluestampedLock.readLock(()-{returnsharedData.get(key);});// 写锁stampedLock.writeLock(()-{sharedData.put(key,newValue);});5.2 注意事项// 警告StampedLock 不支持重入以下代码会死锁stampedLock.writeLock(()-{// 再次尝试获取同一把写锁 —— 死锁stampedLock.writeLock(()-{/* ... */});// 永远不要这样做});六、静态便捷方法按名称缓存锁LockExecutors最强大的特性是按名称缓存锁——相同名称的方法调用共享同一把锁无需手动声明和管理锁对象。6.1 runLock命名重入锁// 名称为 userUpdate 的所有调用共享同一把 ReentrantLockLockExecutors.runLock(userUpdate,()-{userService.update(user);});// 带返回值intcountLockExecutors.runLock(counter,()-{returncounter.incrementAndGet();});典型场景防止同一操作被并发执行如防止重复提交、防并发扣库存。6.2 runReadLock / runWriteLock命名读写锁// 读锁 —— 多线程可同时读 cacheLockObjectvalueLockExecutors.runReadLock(cacheLock,()-{returncache.get(key);});// 写锁 —— 写 cacheLock 时互斥LockExecutors.runWriteLock(cacheLock,()-{cache.put(key,newValue);});6.3 runReadLockOfStampedLock / runWriteLockOfStampedLock// StampedLock 读锁ObjectvalueLockExecutors.runReadLockOfStampedLock(stampedCache,()-{returncache.get(key);});// StampedLock 写锁LockExecutors.runWriteLockOfStampedLock(stampedCache,()-{cache.put(key,newValue);});6.4 removeLock清理缓存锁// 不再使用的锁可以主动移除释放内存LockExecutors.removeLock(userUpdate);七、实战场景7.1 防重复提交PostMapping(/order/create)publicResultVO?createOrder(RequestBodyOrderDTOorder){// 用 userId 固定后缀作为锁名防止同一用户并发下单StringlockNameorder:create:order.getUserId();returnLockExecutors.runLock(lockName,()-{// 检查是否已有进行中的订单if(orderService.hasPendingOrder(order.getUserId())){returnResultVO.fail(您有待处理的订单请勿重复提交);}OrderorderorderService.create(order);returnResultVO.suc(order);});}注意上面的示例中lockName包含动态 userId仅适用于用户量可控的场景。如果用户量巨大如百万级应改用固定名称锁 业务层判重避免缓存无限膨胀。7.2 并发安全的计数器// 多个线程同时调用保证计数准确publicintgetNextSequence(){returnLockExecutors.runLock(sequence:generator,()-{returncurrentSequence;});}7.3 缓存的读写分离ServicepublicclassConfigService{privatefinalMapString,StringconfigCachenewHashMap();// 读配置 —— 多线程可同时读publicStringgetConfig(Stringkey){returnLockExecutors.runReadLock(config:rw,()-{returnconfigCache.get(key);});}// 写配置 —— 互斥写入publicvoidsetConfig(Stringkey,Stringvalue){LockExecutors.runWriteLock(config:rw,()-{configCache.put(key,value);});}// 刷新缓存 —— 互斥操作publicvoidrefreshCache(MapString,StringnewConfig){LockExecutors.runWriteLock(config:rw,()-{configCache.clear();configCache.putAll(newConfig);});}}7.4 批量数据导入防并发// 同一业务类型的导入操作互斥防止重复导入publicImportResultimportData(StringbizType,ListImportRowrows){StringlockNameimport:bizType;returnLockExecutors.runLock(lockName,()-{// 检查是否正在导入if(importService.isRunning(bizType)){returnImportResult.fail(正在导入中请稍后再试);}returnimportService.doImport(rows);});}八、锁名称规范重要使用静态方法时锁名称是缓存的 Key。切勿使用动态变化的业务 ID 作为锁名称否则会导致缓存无限膨胀。// 正确固定名称按业务场景区分LockExecutors.runLock(order:create,()-{/* ... */});LockExecutors.runLock(user:update,()-{/* ... */});LockExecutors.runLock(config:refresh,()-{/* ... */});// 错误动态 ID 作为锁名缓存无限增长LockExecutors.runLock(order:123456,()-{/* ... */});// 每个订单一把锁LockExecutors.runLock(user:789,()-{/* ... */});// 每个用户一把锁// 百万级用户 → 百万把锁 → 内存溢出推荐命名规范模块:操作:lock如order:create:lock、config:refresh:lock。九、类型一致性校验同一名称的锁操作必须使用相同类型否则抛出IllegalArgumentException// 先用 runLock 创建了一个 ReentrantLockLockExecutors.runLock(myLock,()-{/* ... */});// 再用 runReadLock 访问同一名称 —— 抛出异常LockExecutors.runReadLock(myLock,()-{/* ... */});// IllegalArgumentException: 名称 myLock 的锁类型不匹配设计意图防止开发者无意中把读写操作混用同一把互斥锁导致并发性能下降或逻辑错误。十、API 速查表创建执行器方法返回类型说明newReentrantLock()ReentrantLockExecutor创建重入锁执行器newReadWriteLock()ReadWriteLockExecutor创建读写锁执行器newStampedLock()StampedLockExecutor创建 StampedLock 执行器静态便捷方法方法锁类型说明runLock(name, action)ReentrantLock命名重入锁执行runReadLock(name, action)ReadWriteLock命名读锁执行runWriteLock(name, action)ReadWriteLock命名写锁执行runReadLockOfStampedLock(name, action)StampedLock命名 StampedLock 读锁runWriteLockOfStampedLock(name, action)StampedLock命名 StampedLock 写锁缓存管理方法说明removeLock(name)移除指定名称的缓存锁十一、注意事项问题说明锁名称不能动态变化静态方法的缓存基于锁名称用业务 ID 做锁名会导致内存溢出同一名称类型必须一致先用runLock后不能用runReadLock否则抛异常StampedLock 不可重入持有 StampedLock 时再次获取同一把锁会死锁锁缓存生命周期缓存中的锁一直存在不用的锁调用removeLock清理异常安全临界区抛异常时锁仍会正确释放不影响其他线程十二、总结LockExecutors的核心价值维度手写 LockLockExecutors代码量lock/try/finally/unlock 四行模板一行 Lambda锁泄漏风险忘记 finally 就死锁框架自动管理零风险锁管理手动声明、注入、传递按名称缓存即用即取读写分离readLock/writeLock 两套代码readLock/writeLock 两个方法异常安全需要自己保证 finally框架保证无需关心源码地址pan-common如果这篇文章对你有帮助欢迎点赞、收藏、关注后续将持续更新 Java 工具类实战系列。