Java ThreadLocal 内存泄漏代码示例-编程实验室

当ThreadLocal不加static修饰时，会发生每个实例都有自己的 ThreadLocal 对象，这会导致严重的线程数据混乱问题。

本篇博文我通过如下代码来演示这个问题：

修改后的示例：不加`static`的 ThreadLocal

importjava.util.ArrayList;importjava.util.List;classSharedObject{privateintcounter=0;publicvoidincrement(){counter++;}publicintgetCounter(){returncounter;}}classThreadLocalNonStaticExample{// 注意：这里去掉了 static 修饰符！privateThreadLocal<SharedObject>threadLocal=ThreadLocal.withInitial(()->newSharedObject());publicvoidupdateCounter(){SharedObjectshared=threadLocal.get();shared.increment();System.out.println(Thread.currentThread().getName()+" - Counter: "+shared.getCounter()+" - ThreadLocal hash: "+System.identityHashCode(threadLocal));}publicstaticvoidmain(String[]args)throwsInterruptedException{// 创建两个不同的实例ThreadLocalNonStaticExampleexample1=newThreadLocalNonStaticExample();ThreadLocalNonStaticExampleexample2=newThreadLocalNonStaticExample();System.out.println("两个实例的 ThreadLocal 对象是否相同: "+(example1.threadLocal==example2.threadLocal));System.out.println("example1.threadLocal hash: "+System.identityHashCode(example1.threadLocal));System.out.println("example2.threadLocal hash: "+System.identityHashCode(example2.threadLocal));Threadthread1=newThread(()->{System.out.println("\n=== 线程1执行 ===");// 同一个线程，但访问不同实例的 ThreadLocalexample1.updateCounter();// 输出 1example1.updateCounter();// 输出 2example2.updateCounter();// 输出 1 - 因为是不同的 ThreadLocal！},"Thread-1");Threadthread2=newThread(()->{System.out.println("\n=== 线程2执行 ===");example1.updateCounter();// 输出 1 - 新线程，新的 ThreadLocalMapexample2.updateCounter();// 输出 1},"Thread-2");thread1.start();thread1.join();thread2.start();thread2.join();}}

更复杂的场景：内存泄漏风险

classMemoryLeakExample{// 非 static 的 ThreadLocalprivateThreadLocal<List<String>>dataThreadLocal=ThreadLocal.withInitial(()->newArrayList<>());publicvoidaddData(Stringdata){dataThreadLocal.get().add(data);}publicvoidprintData(){System.out.println(Thread.currentThread().getName()+" 数据: "+dataThreadLocal.get());}publicstaticvoidmain(String[]args)throwsInterruptedException{// 模拟大量创建实例List<MemoryLeakExample>examples=newArrayList<>();Threadthread=newThread(()->{for(inti=0;i<1000;i++){MemoryLeakExampleexample=newMemoryLeakExample();examples.add(example);example.addData("data-"+i);if(i%100==0){System.out.println("创建了 "+i+" 个实例");System.out.println("当前线程 ThreadLocalMap 中的 Entry 数量会不断增加...");}}// 每个实例都有自己的 ThreadLocal 对象作为 key// 在 ThreadLocalMap 中会有大量 Entry！});thread.start();thread.join();System.out.println("\n总计创建了 "+examples.size()+" 个实例");System.out.println("这意味着在当前线程的 ThreadLocalMap 中有 "+examples.size()+" 个不同的 ThreadLocal key！");}}

在线程池中的灾难性后果

importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;classThreadPoolProblem{// 非 static ThreadLocalprivateThreadLocal<Integer>counterThreadLocal=ThreadLocal.withInitial(()->0);publicvoidincrement(){Integercount=counterThreadLocal.get();counterThreadLocal.set(count+1);}publicintgetCount(){returncounterThreadLocal.get();}publicstaticvoidmain(String[]args)throwsInterruptedException{ExecutorServiceexecutor=Executors.newFixedThreadPool(2);// 任务：每个任务创建一个新实例for(inti=0;i<10;i++){inttaskId=i;executor.submit(()->{ThreadPoolProbleminstance=newThreadPoolProblem();instance.increment();instance.increment();System.out.println("任务 "+taskId+"，线程: "+Thread.currentThread().getName()+"，计数: "+instance.getCount()+"，ThreadLocal hash: "+System.identityHashCode(instance.counterThreadLocal));// 问题：线程池线程复用，但每次任务都创建新的 ThreadLocal// 导致 ThreadLocalMap 中积累大量 stale entries});}executor.shutdown();}}

不加`static`的问题总结

线程隔离失效：
- 每个实例有自己的ThreadLocal对象
- 同一个线程访问不同实例时，会使用不同的ThreadLocalkey
- 无法实现真正意义上的线程级数据共享

内存泄漏：

// 每次创建新实例ThreadLocalNonStaticExampleobj=newThreadLocalNonStaticExample();// 都会创建新的 ThreadLocal 对象// ThreadLocalMap 中会积累：ThreadLocal(key) -> value// 线程不结束，这些 entry 就一直存在

ThreadLocalMap 膨胀：
- 每个线程的ThreadLocalMap中会有大量 key（每个实例一个）
- 即使实例被回收，ThreadLocal 是弱引用，但 value 可能还在

数据不一致：

// 线程1example1.updateCounter();// 使用 example1.threadLocalexample2.updateCounter();// 使用 example2.threadLocal（不同的存储位置！）// 它们不是同一个 ThreadLocal，所以不共享数据

性能问题：
- 每次都要创建新的ThreadLocal对象
- ThreadLocalMap查找效率降低（hash 冲突增加）

正确 vs 错误对比

// ✅ 正确：static ThreadLocalpublicclassCorrectExample{privatestaticThreadLocal<Context>context=ThreadLocal.withInitial(Context::new);// 所有实例共享同一个 ThreadLocal 对象// 线程数据真正隔离}// ❌ 错误：非 static ThreadLocalpublicclassWrongExample{privateThreadLocal<Context>context=ThreadLocal.withInitial(Context::new);// 每个实例都有自己的 ThreadLocal// 线程数据混乱}