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

《Java 100 天进阶之路》第60.4篇：多线程代码示例集（2026版）

news 2026/7/15 20:55:48

第60.4篇：多线程代码示例集（2026版）

📌系列导航：《Java 100 天进阶之路》完整目录 |
⬅️ 上一篇：第60.3篇：多线程生产环境避坑清单 |
➡️ 下一篇：第61篇：JVM内存区域（待发布）

🗺️ 本文阅读地图（2 分钟速览）

多线程面试不仅问原理，还要写代码。本文汇总 10 个可直接背诵的代码模板，覆盖线程创建、锁使用、线程池、异步编排、原子类、ThreadLocal 等所有场景：

分类	代码模板数量
线程创建	2 个模板
锁与并发工具	3 个模板
线程池	2 个模板
异步编程	1 个模板
原子类与 CAS	1 个模板
ThreadLocal	1 个模板

文章目录

- 第60.4篇：多线程代码示例集（2026版）
- - 🗺️ 本文阅读地图（2 分钟速览）
  - 模板1：线程创建方式
  - - 方式一：继承 Thread
    - 方式二：实现 Runnable（推荐）
    - 方式三：实现 Callable（有返回值）
    - 方式四：线程池 + 虚拟线程
  - 模板2：synchronized 三种用法
  - - 用法一：修饰实例方法（锁 this）
    - 用法二：修饰静态方法（锁 Class）
    - 用法三：修饰代码块（粒度最细）
  - 模板3：ReentrantLock 标准模板
  - - 独占锁
    - tryLock 超时模板（防死锁）
  - 模板4：死锁演示代码（面试手写）
  - 模板5：线程池标准创建模板
  - 模板6：CompletableFuture 异步编排
  - 模板7：原子类使用
  - - AtomicInteger 计数器
    - LongAdder 高并发计数器
    - AtomicStampedReference（ABA 解决）
    - AtomicIntegerFieldUpdater（零内存开销）
  - 模板8：ThreadLocal 标准用法
  - - 基础用法 + remove
    - 静态 ThreadLocal + 初始化
    - 跨线程池传递（TTL）
- 📊 你的学习进度
- 👉 下一篇文章预告

模板1：线程创建方式

方式一：继承 Thread

classMyThreadextendsThread{@Overridepublicvoidrun(){System.out.println("线程: "+Thread.currentThread().getName());}}newMyThread().start();

方式二：实现 Runnable（推荐）

Runnabletask=()->System.out.println("线程: "+Thread.currentThread().getName());newThread(task).start();

方式三：实现 Callable（有返回值）

Callable<String>task=()->{Thread.sleep(1000);return"结果";};FutureTask<String>ft=newFutureTask<>(task);newThread(ft).start();Stringresult=ft.get();// 阻塞获取结果

方式四：线程池 + 虚拟线程

// 传统线程池ExecutorServicepool=newThreadPoolExecutor(5,10,60L,TimeUnit.SECONDS,newArrayBlockingQueue<>(100),r->newThread(r,"biz-pool-%d"),newThreadPoolExecutor.CallerRunsPolicy());pool.execute(()->System.out.println("任务"));// 虚拟线程（JDK 21+）Thread.startVirtualThread(()->System.out.println("虚拟线程"));ExecutorServicevPool=Executors.newVirtualThreadPerTaskExecutor();vPool.submit(()->System.out.println("虚拟线程池任务"));

模板2：synchronized 三种用法

用法一：修饰实例方法（锁 this）

publicsynchronizedvoidmethodA(){// 同一实例的 synchronized 方法互斥}

用法二：修饰静态方法（锁 Class）

publicstaticsynchronizedvoidmethodB(){// 该类的所有实例互斥}

用法三：修饰代码块（粒度最细）

privatefinalObjectlock=newObject();publicvoidmethodC(){synchronized(lock){// 只锁这部分}}

模板3：ReentrantLock 标准模板

独占锁

ReentrantLocklock=newReentrantLock();lock.lock();try{// 业务逻辑}finally{lock.unlock();// 必须在 finally 中释放}

tryLock 超时模板（防死锁）

ReentrantLocklockA=newReentrantLock();ReentrantLocklockB=newReentrantLock();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{privatestaticfinalObjectA=newObject();privatestaticfinalObjectB=newObject();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_CORES=Runtime.getRuntime().availableProcessors();// IO 密集型线程池publicstaticfinalExecutorServiceIO_POOL=newThreadPoolExecutor(CPU_CORES*2,CPU_CORES*4,60L,TimeUnit.SECONDS,newArrayBlockingQueue<>(1000),r->newThread(r,"io-pool-"+System.currentTimeMillis()),newThreadPoolExecutor.CallerRunsPolicy());// CPU 密集型线程池publicstaticfinalExecutorServiceCPU_POOL=newThreadPoolExecutor(CPU_CORES,CPU_CORES+1,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();}}}

模板6：CompletableFuture 异步编排

// 串行依赖CompletableFuture.supplyAsync(()->1).thenApply(x->x+1).thenApply(x->x*2).thenAccept(System.out::println);// 并行合并CompletableFuture<Integer>f1=CompletableFuture.supplyAsync(()->10);CompletableFuture<Integer>f2=CompletableFuture.supplyAsync(()->20);f1.thenCombine(f2,Integer::sum).thenAccept(System.out::println);// 多任务聚合 + 超时 + 异常CompletableFuture<Void>all=CompletableFuture.allOf(f1,f2,f3);all.completeOnTimeout(null,3,TimeUnit.SECONDS).exceptionally(e->{log.error("",e);returnnull;}).join();

模板7：原子类使用

AtomicInteger 计数器

AtomicIntegercount=newAtomicInteger(0);count.incrementAndGet();// 返回新值count.getAndIncrement();// 返回旧值count.compareAndSet(5,10);

LongAdder 高并发计数器

LongAdderadder=newLongAdder();adder.increment();adder.add(5);longtotal=adder.sum();// 弱一致性

AtomicStampedReference（ABA 解决）

AtomicStampedReference<String>ref=newAtomicStampedReference<>("A",0);int[]stamp=newint[1];Stringold=ref.get(stamp);ref.compareAndSet(old,"B",stamp[0],stamp[0]+1);

AtomicIntegerFieldUpdater（零内存开销）

classUser{volatileintage;}AtomicIntegerFieldUpdater<User>updater=AtomicIntegerFieldUpdater.newUpdater(User.class,"age");Useruser=newUser();updater.incrementAndGet(user);

模板8：ThreadLocal 标准用法

基础用法 + remove

publicclassThreadLocalDemo{privatestaticfinalThreadLocal<String>CONTEXT=newThreadLocal<>();publicvoidprocess(StringuserId){try{CONTEXT.set(userId);doBusiness();}finally{CONTEXT.remove();// 必须！}}privatevoiddoBusiness(){StringuserId=CONTEXT.get();// ...}}

静态 ThreadLocal + 初始化

privatestaticfinalThreadLocal<SimpleDateFormat>DATE_FORMAT=ThreadLocal.withInitial(()->newSimpleDateFormat("yyyy-MM-dd HH:mm:ss"));// 使用：DATE_FORMAT.get().format(new Date());

跨线程池传递（TTL）

// 引入依赖：com.alibaba:transmittable-thread-localTransmittableThreadLocal<String>ttl=newTransmittableThreadLocal<>();ttl.set("traceId");Runnabletask=TtlRunnable.get(()->System.out.println(ttl.get()));threadPool.submit(task);