我要评论什么是ThreadLocal
本质上，ThreadLocal通过空间来换取时间，从而实现每个线程当中都会有一个变量的副本，这样每个线程就会操作改副本，从而完全规避了多线程的并发问题。
public T get() { // 获取到当前线程对象 Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null) { ThreadLocalMap.Entry e = map.getEntry(this); if (e != null) { @SuppressWarnings("unchecked") T result = (T)e.value; return result; } } return setInitialValue(); } public void set(T value) { Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null) map.set(this, value); else createMap(t, value); } 静态内部类
static class ThreadLocalMap { static class Entry extends WeakReference<ThreadLocal<?>> { /** The value associated with this ThreadLocal. */ Object value; Entry(ThreadLocal<?> k, Object v) { super(k); value = v; } } ... } 每个线程Thread都维护了自己的threadLocals变量，所以在每个线程创建ThreadLocal的时候，实际上数据是存在自己线程Thread的threadLocals变量里面的，别人没办法拿到，从而实现了隔离。
public class Thread implements Runnable { ... /* ThreadLocal values pertaining to this thread. This map is maintained
* by the ThreadLocal class. */ ThreadLocal.ThreadLocalMap threadLocals = null; ... } Java中存在四种类型的引用：
-
强引用（strong）
垃圾回收不回收。 -
软引用（soft）
在垃圾回收的时候，如果内存不够，则清理，否则不清理。 -
弱引用（weak）
在下一次垃圾回收时，如果一个对象是弱引用，gc清理，对象被回收。 - 虚引用（phantom）
除了强引用用=new，其他三种都继承Reference：
public class WeakReference<T> extends Reference<T> {} ThreadLocal Entry为什么继承WeakReference
防止内存泄漏，如果Entry是强引用，Entry中的k永远无法得到释放，k,v越来越多。。。如果Entry是弱引用，在下一次垃圾回收的时候，弱引用ThreadLocal将会被回收。
static class Entry extends WeakReference<ThreadLocal<?>> {} ThreadLocal内存泄漏
内存泄漏的原因
Entry：k，v
Entry是弱引用，在下一次垃圾回收的时候，弱引用ThreadLocal将会被回收。Entry的k将指向null（k指向的ThreadLocal已经被回收），v将不能再被获取。造成内存泄漏。
怎么解决
ThreadLocal在set或者get方法的时候，程序会检查Entry数组，将k为null的Entry一一remove掉。
private void set(ThreadLocal<?> key, Object value) { // We don't use a fast path as with get() because it is at // least as common to use set() to create new entries as // it is to replace existing ones, in which case, a fast // path would fail more often than not. Entry[] tab = table; int len = tab.length; int i = key.threadLocalHashCode & (len-1); for (Entry e = tab[i]; e != null; e = tab[i = nextIndex(i, len)]) { ThreadLocal<?> k = e.get(); if (k == key) { e.value = value; return; } // 替换k为空的Entry if (k == null) { replaceStaleEntry(key, value, i); return; } } tab[i] = new Entry(key, value); int sz = ++size; if (!cleanSomeSlots(i, sz) && sz >= threshold) rehash(); } 在使用完ThreadLocal后执行remove方法
package com.learn.thread.local public class ThreadLocalTest { private static final ThreadLocal<String> name = new ThreadLocal(); public static void main(String[] args) { try { name.set("John"); System.out.println(checkUser()); } finally { name.remove(); } System.out.println(name.get()); } public static String checkUser() { if (name.get() == null) { return ""; } return name.get(); } }
本文地址：https://blog.csdn.net/wz122330/article/details/107666723
您可能感兴趣的文章:
如您对本文有疑问或者有任何想说的，请点击进行留言回复，万千网友为您解惑！
网友评论