尧图网络 高端网站定制 · 原创设计
免费咨询热线
400-888-6620
免费获取方案
《Java 100 天进阶之路》第60.4篇:多线程代码示例集(2026版)
第60.4篇多线程代码示例集2026版系列导航《Java 100 天进阶之路》完整目录 |⬅️ 上一篇第60.3篇多线程生产环境避坑清单 |➡️ 下一篇第61篇JVM内存区域待发布️ 本文阅读地图2 分钟速览多线程面试不仅问原理还要写代码。本文汇总 10 个可直接背诵的代码模板覆盖线程创建、锁使用、线程池、异步编排、原子类、ThreadLocal 等所有场景分类代码模板数量线程创建2 个模板锁与并发工具3 个模板线程池2 个模板异步编程1 个模板原子类与 CAS1 个模板ThreadLocal1 个模板文章目录第60.4篇多线程代码示例集2026版️ 本文阅读地图2 分钟速览模板1线程创建方式方式一继承 Thread方式二实现 Runnable推荐方式三实现 Callable有返回值方式四线程池 虚拟线程模板2synchronized 三种用法用法一修饰实例方法锁 this用法二修饰静态方法锁 Class用法三修饰代码块粒度最细模板3ReentrantLock 标准模板独占锁tryLock 超时模板防死锁模板4死锁演示代码面试手写模板5线程池标准创建模板模板6CompletableFuture 异步编排模板7原子类使用AtomicInteger 计数器LongAdder 高并发计数器AtomicStampedReferenceABA 解决AtomicIntegerFieldUpdater零内存开销模板8ThreadLocal 标准用法基础用法 remove静态 ThreadLocal 初始化跨线程池传递TTL 你的学习进度 下一篇文章预告模板1线程创建方式方式一继承 ThreadclassMyThreadextendsThread{Overridepublicvoidrun(){System.out.println(线程: Thread.currentThread().getName());}}newMyThread().start();方式二实现 Runnable推荐Runnabletask()-System.out.println(线程: Thread.currentThread().getName());newThread(task).start();方式三实现 Callable有返回值CallableStringtask()-{Thread.sleep(1000);return结果;};FutureTaskStringftnewFutureTask(task);newThread(ft).start();Stringresultft.get();// 阻塞获取结果方式四线程池 虚拟线程// 传统线程池ExecutorServicepoolnewThreadPoolExecutor(5,10,60L,TimeUnit.SECONDS,newArrayBlockingQueue(100),r-newThread(r,biz-pool-%d),newThreadPoolExecutor.CallerRunsPolicy());pool.execute(()-System.out.println(任务));// 虚拟线程JDK 21Thread.startVirtualThread(()-System.out.println(虚拟线程));ExecutorServicevPoolExecutors.newVirtualThreadPerTaskExecutor();vPool.submit(()-System.out.println(虚拟线程池任务));模板2synchronized 三种用法用法一修饰实例方法锁 thispublicsynchronizedvoidmethodA(){// 同一实例的 synchronized 方法互斥}用法二修饰静态方法锁 ClasspublicstaticsynchronizedvoidmethodB(){// 该类的所有实例互斥}用法三修饰代码块粒度最细privatefinalObjectlocknewObject();publicvoidmethodC(){synchronized(lock){// 只锁这部分}}模板3ReentrantLock 标准模板独占锁ReentrantLocklocknewReentrantLock();lock.lock();try{// 业务逻辑}finally{lock.unlock();// 必须在 finally 中释放}tryLock 超时模板防死锁ReentrantLocklockAnewReentrantLock();ReentrantLocklockBnewReentrantLock();if(lockA.tryLock(1,TimeUnit.SECONDS)){try{if(lockB.tryLock(1,TimeUnit.SECONDS)){try{// 两把锁都拿到执行业务}finally{lockB.unlock();}}}finally{if(!lockB.isHeldByCurrentThread()){lockA.unlock();// 获取B失败释放A}}}else{// 超时处理}模板4死锁演示代码面试手写publicclassDeadlockDemo{privatestaticfinalObjectAnewObject();privatestaticfinalObjectBnewObject();publicstaticvoidmain(String[]args){newThread(()-{synchronized(A){try{Thread.sleep(100);}catch(InterruptedExceptione){}synchronized(B){System.out.println(线程1 获取B);}}}).start();newThread(()-{synchronized(B){try{Thread.sleep(100);}catch(InterruptedExceptione){}synchronized(A){System.out.println(线程2 获取A);}}}).start();}}模板5线程池标准创建模板publicclassAsyncThreadPool{privatestaticfinalintCPU_CORESRuntime.getRuntime().availableProcessors();// IO 密集型线程池publicstaticfinalExecutorServiceIO_POOLnewThreadPoolExecutor(CPU_CORES*2,CPU_CORES*4,60L,TimeUnit.SECONDS,newArrayBlockingQueue(1000),r-newThread(r,io-pool-System.currentTimeMillis()),newThreadPoolExecutor.CallerRunsPolicy());// CPU 密集型线程池publicstaticfinalExecutorServiceCPU_POOLnewThreadPoolExecutor(CPU_CORES,CPU_CORES1,60L,TimeUnit.SECONDS,newArrayBlockingQueue(100),r-newThread(r,cpu-pool-System.currentTimeMillis()),newThreadPoolExecutor.AbortPolicy());// 优雅关闭publicstaticvoidshutdown(ExecutorServicepool){pool.shutdown();try{if(!pool.awaitTermination(60,TimeUnit.SECONDS)){pool.shutdownNow();}}catch(InterruptedExceptione){pool.shutdownNow();Thread.currentThread().interrupt();}}}模板6CompletableFuture 异步编排// 串行依赖CompletableFuture.supplyAsync(()-1).thenApply(x-x1).thenApply(x-x*2).thenAccept(System.out::println);// 并行合并CompletableFutureIntegerf1CompletableFuture.supplyAsync(()-10);CompletableFutureIntegerf2CompletableFuture.supplyAsync(()-20);f1.thenCombine(f2,Integer::sum).thenAccept(System.out::println);// 多任务聚合 超时 异常CompletableFutureVoidallCompletableFuture.allOf(f1,f2,f3);all.completeOnTimeout(null,3,TimeUnit.SECONDS).exceptionally(e-{log.error(,e);returnnull;}).join();模板7原子类使用AtomicInteger 计数器AtomicIntegercountnewAtomicInteger(0);count.incrementAndGet();// 返回新值count.getAndIncrement();// 返回旧值count.compareAndSet(5,10);LongAdder 高并发计数器LongAdderaddernewLongAdder();adder.increment();adder.add(5);longtotaladder.sum();// 弱一致性AtomicStampedReferenceABA 解决AtomicStampedReferenceStringrefnewAtomicStampedReference(A,0);int[]stampnewint[1];Stringoldref.get(stamp);ref.compareAndSet(old,B,stamp[0],stamp[0]1);AtomicIntegerFieldUpdater零内存开销classUser{volatileintage;}AtomicIntegerFieldUpdaterUserupdaterAtomicIntegerFieldUpdater.newUpdater(User.class,age);UserusernewUser();updater.incrementAndGet(user);模板8ThreadLocal 标准用法基础用法 removepublicclassThreadLocalDemo{privatestaticfinalThreadLocalStringCONTEXTnewThreadLocal();publicvoidprocess(StringuserId){try{CONTEXT.set(userId);doBusiness();}finally{CONTEXT.remove();// 必须}}privatevoiddoBusiness(){StringuserIdCONTEXT.get();// ...}}静态 ThreadLocal 初始化privatestaticfinalThreadLocalSimpleDateFormatDATE_FORMATThreadLocal.withInitial(()-newSimpleDateFormat(yyyy-MM-dd HH:mm:ss));// 使用DATE_FORMAT.get().format(new Date());跨线程池传递TTL// 引入依赖com.alibaba:transmittable-thread-localTransmittableThreadLocalStringttlnewTransmittableThreadLocal();ttl.set(traceId);RunnabletaskTtlRunnable.get(()-System.out.println(ttl.get()));threadPool.submit(task); 你的学习进度当前第60.4篇 ·多线程专题外挂代码示例集✅ 已完成基础篇44篇 第45~60篇 第60.1~60.4篇 正在学第60.4篇⏳ 待学习第61~108篇 完整目录 学习指南 | 订阅本专栏不错过每一篇 下一篇文章预告下一篇《第61篇JVM内存区域》内容简介JVM 内存布局堆、元空间、虚拟机栈、本地方法栈、程序计数器、JDK 8 变化、各区域内存溢出场景与排查。JVM 调优与故障排查专题正式开启《Java 100 天进阶之路 | 从入门到上岗就业》每天一篇建议收藏 关注一起100天拿offer 点击关注我更新后第一时间收到推送
RELATED

相关推荐

不断演化的城市环境中无人机的动态空域管理:协同合作与人类安全

不断演化的城市环境中无人机的动态空域管理:协同合作与人类安全

大家读完觉得有帮助记得关注和点赞!!! 摘要 低空经济是一个具有巨大发展潜力的新兴产业,其中无人驾驶飞行器(UAV)运行的安全性是一个关键挑战。特别是在复杂的城市地形和有人环境中,无人机空域…

📅 2026/10/7 12:38:55
高速ADC核心性能与JESD204B接口设计实战解析

高速ADC核心性能与JESD204B接口设计实战解析

1. 项目概述:为什么我们需要ADC31JB68这样的高速ADC?在无线通信、雷达探测或者高端测试仪器里,我们工程师常常面临一个核心挑战:如何把现实世界中瞬息万变、频率极高的模拟信号,一丝不苟地“搬进”数字世界进行处理&am…

📅 2026/10/25 12:05:59
包装生产线PLC控制系统设计资料12(设计源文件+万字报告+讲解)(支持资料、图片参考_相关定制)_

包装生产线PLC控制系统设计资料12(设计源文件+万字报告+讲解)(支持资料、图片参考_相关定制)_

包装生产线PLC控制系统设计资料12(设计源文件万字报告讲解)(支持资料、图片参考_相关定制)_ 包含完整程序、CAD图pdf版、课程设计指导书和课设报告。 内容包括: -包装生产线控制系统示意图 -包装生产线控制系统控制电路图-包装生产线控制系统外部接线图 …

📅 2026/9/12 23:29:24
MORE NEWS

更多资讯

📰

跨境电商数据中台架构设计与实战应用

1. 项目背景与核心价值 跨境零售行业近年来呈现爆发式增长态势,但随之而来的数据管理难题也日益凸显。我在为多家跨境电商企业提供技术咨询时发现,这些企业普遍面临着订单数据分散在10余个海外平台、用户行为日志存储在5种不同系统、供应链数据与财务系统…

📰

Kappa架构在金融风控中的实时流处理实践

1. Kappa架构与金融风控的天然契合 第一次接触Kappa架构是在2018年某股份制银行的实时反欺诈系统改造项目中。当时我们面临的核心痛点是:传统Lambda架构中批处理和实时处理两套代码的维护成本居高不下,而风控规则每周至少迭代3-4次的频率让团队疲于奔命。…

📰

C++ STL list底层原理与高效应用指南

1. 深入理解C STL list的底层结构与核心特性 1.1 双向循环链表:list的物理实现 在C标准模板库(STL)中,list容器本质上是一个带头结点的双向循环链表。这个设计决定了它与其他序列容器(如vector、deque)截然不同的行为特征。让我们拆解这个结构的每个关键…

📰

大模型实操指南:从本地部署到PPT级可控生成

1. 这不是“学大模型”,而是重建你和信息世界的关系“大模型相关内容的研究学习”——看到这个标题,我第一反应是笑。不是嘲笑,是那种在实验室熬了三个通宵、刚调通一个LoRA微调任务后,盯着终端里跳出来的loss曲线突然失语的笑。因…

📰

高效查找第K大元素:排序、堆与快速选择算法对比

1. 问题描述与核心挑战 给定整数数组 nums 和整数 k,我们需要找到数组中第 k 个最大的元素。请注意,这里要求的是排序后的第 k 个最大元素,而不是第 k 个不同的元素。 这个问题看似简单,但隐藏着几个关键挑战: 当数组…

📰

企业设备数字化管理:易点易动系统实践指南

1. 设备管理在企业数字化转型中的核心价值 设备管理作为企业资产管理的重要组成部分,正在经历从传统人工记录向数字化、智能化管理的转变。在制造业、医疗、教育等行业,设备资产往往占据企业总资产的60%以上,其管理效率直接影响企业运营成本和…

TODAY

今日更新

THIS WEEK

本周精选

THIS MONTH

本月热门

读完文章,想聊聊您的网站?

告诉我们您的行业与需求,资深顾问一对一梳理方案与报价,全程免费。

📞 💬