線程封閉
當訪問共享的可變數(shù)據(jù)時瓶蚂，通常需要使用同步嗡午；一種避免使用同步的方式就是不共享數(shù)據(jù)腿宰；如何數(shù)據(jù)僅僅被一個線程訪問，就不需要同步猖毫，該技術(shù)就是線程封閉。
ThreadLocal就是其中一種實現(xiàn)须喂。
ThreaLocal常見使用
線程池:由于JDBC連接對象不一定是線程安全的吁断，因此，當多個線程在沒有協(xié)同的情況下使用全局變量時坞生，就不是線程安全的仔役。通過將JDBC的連接保存到ThreadLocal對象中，每個線程都擁有屬于自己的連接是己。
private static ThreadLocal<Connection> connectionHolder = new
ThreadLocal<Connection>() {
@Override
protected Connection initialValue() {
return DriverManager.getConnection("");
}
};
public static Condition getConnection() {
return connectionHolder.get();
}
除此之外又兵，Spring等各種框架大量使用了ThreadLocal(使用它來保存上下文)。
原理
Thread
在Thread對象中有一個變量(鉤子)卒废，保存Map對象沛厨。?
/* ThreadLocal values pertaining to this thread. This map is maintained
* by the ThreadLocal class. */
ThreadLocal.ThreadLocalMap threadLocals = null;
當你調(diào)用ThreadLocal中的set方法時就會生成一個Map對象，把這個Map對象賦值給Thread對象摔认。
ThreadLocal
設(shè)值
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value); // 以ThreadLocal對象作為key設(shè)值
else
createMap(t, value);
}
ThreadLocalMap getMap(Thread t) {
return t.threadLocals;
}
void createMap(Thread t, T firstValue) {
t.threadLocals = new ThreadLocalMap(this, firstValue);
}
取值
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();
}
private T setInitialValue() {
T value = initialValue();
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
return value;
}
protected T initialValue() { // 該方法可以重新設(shè)置初始化值
return null;
}
ThreadLocal本質(zhì)上是給每個線程綁定一個Map對象逆皮，該Map對象key是ThreadLocal本身，value是要設(shè)置的值参袱；這樣每個value就僅僅可以被該線程自己訪問到电谣，外部其他線程不會訪問到該對象，實現(xiàn)了線程安全蓖柔。
Thread與ThreadLocal關(guān)系
Thread和ThreadLocal之間有著很緊密的關(guān)系辰企，Thread中的Map持有ThreadLocal對象(以它作為key)。
| Thread | ThreadLocal |
|---|---|
| 死亡 | 死亡 |
| 存活 | 存活 |
| 存活 | 死亡 |
| 死亡 | 存活 |
當兩者之間都已經(jīng)死亡時况鸣，自然會被GC回收牢贸；當兩者都“存活”時，GC不會回收它們镐捧；那么當Thread或ThreadLocal兩者之間一個“死亡”時情況是什么樣呢潜索。
Thread死亡
當Thread死亡時臭增，線程中Map也不存在了，因為Map被回收竹习，Map中保存的key誊抛、value也會根據(jù)是否還被引用來決定是否被回收，不會導(dǎo)致內(nèi)存泄露整陌。
ThreadLocal死亡
當ThreadLocal死亡時拗窃，線程依然存活，Map還在泌辫，但是Map中一個以該ThreadLocal為key的Entry需要失效随夸，該Entry中的key和value應(yīng)該被GC。
為了實現(xiàn)這一點震放，ThreadLocal中的Entry實現(xiàn):
static class Entry extends WeakReference<ThreadLocal<?>> {
/** The value associated with this ThreadLocal. */
Object value;
Entry(ThreadLocal<?> k, Object v) {
super(k);
value = v;
}
}
這樣宾毒，當ThreadLocal死亡時，因為Entry中key是弱引用殿遂，GC依然會回收該對象诈铛，不會導(dǎo)致內(nèi)存泄露。
而Entry中該key對應(yīng)value的回收是通過下列方法實現(xiàn)的:
private boolean cleanSomeSlots(int i, int n) {
boolean removed = false;
Entry[] tab = table;
int len = tab.length;
do {
i = nextIndex(i, len);
Entry e = tab[i];
if (e != null && e.get() == null) { // e.get() point
n = len;
removed = true;
i = expungeStaleEntry(i);
}
} while ( (n >>>= 1) != 0);
return removed;
}
expungeStaleEntry方法中:
e.value = null; // value set null
tab[i] = null;
size--;
通過該方法把value設(shè)置為null墨礁，以便在下次GC時能夠及時回收該對象幢竹；ThreadLocal死亡時不會導(dǎo)致內(nèi)存泄露。
注意
當前很多技術(shù)都是使用的線程池技術(shù)恩静，線程不會頻繁的創(chuàng)建銷毀妨退，那么存在一種可能性，比如線程池中一個線程拿到全局ThreadLocal對象并設(shè)置了一個很大的字符串對象蜕企，使用過后沒有remove操作，那么由于線程和ThreadLocal都是存活的冠句，那么該字符串對象是不會被回收的轻掩，導(dǎo)致內(nèi)存泄露，所以當使用完畢后線程最好調(diào)用ThreadLocal中的remove方法懦底，及時移除該對象唇牧，防止不必要的內(nèi)存損耗。
